This is an automated email from the ASF dual-hosted git repository. justinchen pushed a commit to branch fix-alter-column-type in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 8ba7eb6613bf2503b6de0229bd74a3f6679d41b1 Author: Caideyipi <[email protected]> AuthorDate: Wed Apr 15 10:11:37 2026 +0800 Update AlterTableColumnDataTypeProcedure.java --- .../impl/schema/table/AlterTableColumnDataTypeProcedure.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/AlterTableColumnDataTypeProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/AlterTableColumnDataTypeProcedure.java index fb02c1c2e59..bdfc314c49a 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/AlterTableColumnDataTypeProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/AlterTableColumnDataTypeProcedure.java @@ -26,7 +26,6 @@ import org.apache.iotdb.commons.schema.table.TsTable; import org.apache.iotdb.confignode.consensus.request.write.table.AlterColumnDataTypePlan; import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv; import org.apache.iotdb.confignode.procedure.exception.ProcedureException; -import org.apache.iotdb.confignode.procedure.impl.schema.SchemaUtils; import org.apache.iotdb.confignode.procedure.state.schema.AlterTableColumnDataTypeState; import org.apache.iotdb.confignode.procedure.store.ProcedureType; import org.apache.iotdb.rpc.TSStatusCode; @@ -142,8 +141,11 @@ public class AlterTableColumnDataTypeProcedure private void alterColumnDataType(final ConfigNodeProcedureEnv env) { final TSStatus status = - SchemaUtils.executeInConsensusLayer( - new AlterColumnDataTypePlan(database, tableName, columnName, dataType), env, LOGGER); + env.getConfigManager() + .getClusterSchemaManager() + .executePlan( + new AlterColumnDataTypePlan(database, tableName, columnName, dataType), + isGeneratedByPipe); if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()) { setFailure(new ProcedureException(new IoTDBException(status.getMessage(), status.getCode()))); }
