From ae5877344afe09dc4508dbad370fc3ef0a9e8c9e Mon Sep 17 00:00:00 2001 From: libo Date: Wed, 21 Jan 2026 19:34:49 +0800 Subject: [PATCH 1/2] Fix the problem that "StateMachineProceduree not set next state, but return HAS_MORE_STATE". --- .../procedure/impl/schema/AlterTimeSeriesDataTypeProcedure.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/AlterTimeSeriesDataTypeProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/AlterTimeSeriesDataTypeProcedure.java index ccd83014f643..ad1d04ca6eeb 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/AlterTimeSeriesDataTypeProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/AlterTimeSeriesDataTypeProcedure.java @@ -124,7 +124,7 @@ protected StateMachineProcedure.Flow executeFromState( this::setFailure, true); collectPayload4Pipe(env); - break; + return Flow.NO_MORE_STATE; default: setFailure( new ProcedureException( From c6218336b3b353bea167b4aaf124aedd6eb42f46 Mon Sep 17 00:00:00 2001 From: libo Date: Mon, 26 Jan 2026 18:36:13 +0800 Subject: [PATCH 2/2] Adjust error message. --- .../impl/schema/AlterTimeSeriesDataTypeProcedure.java | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/AlterTimeSeriesDataTypeProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/AlterTimeSeriesDataTypeProcedure.java index 05daf8c900de..2bbfde0e142f 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/AlterTimeSeriesDataTypeProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/AlterTimeSeriesDataTypeProcedure.java @@ -235,11 +235,8 @@ protected void onAllReplicasetFailure( new ProcedureException( new MetadataException( String.format( - "Alter timeseries %s data type from %s to %s in schema regions failed. Failures: %s", - measurementPath.getFullPath(), - measurementPath.getSeriesType(), - dataType, - printFailureMap())))); + "Alter timeseries %s data type to %s in schema regions failed. Failures: %s", + measurementPath.getFullPath(), dataType, printFailureMap())))); interruptTask(); } };