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
The following commit(s) were added to refs/heads/fix-alter-column-type by this
push:
new 253af30316c pre
253af30316c is described below
commit 253af30316ce8747461e84a7ba46068f093ab708
Author: Caideyipi <[email protected]>
AuthorDate: Wed Apr 15 10:52:27 2026 +0800
pre
---
.../consensus/request/ConfigPhysicalPlan.java | 4 ++++
.../request/ConfigPhysicalPlanSerDeTest.java | 27 ++++++++++++++++++----
2 files changed, 27 insertions(+), 4 deletions(-)
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlan.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlan.java
index 7fd7cd02911..ffe333b56dd 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlan.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlan.java
@@ -105,6 +105,7 @@ import
org.apache.iotdb.confignode.consensus.request.write.table.AlterColumnData
import
org.apache.iotdb.confignode.consensus.request.write.table.CommitCreateTablePlan;
import
org.apache.iotdb.confignode.consensus.request.write.table.CommitDeleteColumnPlan;
import
org.apache.iotdb.confignode.consensus.request.write.table.CommitDeleteTablePlan;
+import
org.apache.iotdb.confignode.consensus.request.write.table.PreAlterColumnDataTypePlan;
import
org.apache.iotdb.confignode.consensus.request.write.table.PreCreateTablePlan;
import
org.apache.iotdb.confignode.consensus.request.write.table.PreDeleteColumnPlan;
import
org.apache.iotdb.confignode.consensus.request.write.table.PreDeleteTablePlan;
@@ -445,6 +446,9 @@ public abstract class ConfigPhysicalPlan implements
IConsensusRequest {
case PreDeleteViewColumn:
plan = new PreDeleteViewColumnPlan();
break;
+ case PreAlterColumnDataType:
+ plan = new PreAlterColumnDataTypePlan();
+ break;
case AlterColumnDataType:
plan = new AlterColumnDataTypePlan();
break;
diff --git
a/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlanSerDeTest.java
b/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlanSerDeTest.java
index 109e3c0d337..6bb97131f63 100644
---
a/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlanSerDeTest.java
+++
b/iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/consensus/request/ConfigPhysicalPlanSerDeTest.java
@@ -138,6 +138,7 @@ import
org.apache.iotdb.confignode.consensus.request.write.table.AlterColumnData
import
org.apache.iotdb.confignode.consensus.request.write.table.CommitCreateTablePlan;
import
org.apache.iotdb.confignode.consensus.request.write.table.CommitDeleteColumnPlan;
import
org.apache.iotdb.confignode.consensus.request.write.table.CommitDeleteTablePlan;
+import
org.apache.iotdb.confignode.consensus.request.write.table.PreAlterColumnDataTypePlan;
import
org.apache.iotdb.confignode.consensus.request.write.table.PreCreateTablePlan;
import
org.apache.iotdb.confignode.consensus.request.write.table.PreDeleteColumnPlan;
import
org.apache.iotdb.confignode.consensus.request.write.table.PreDeleteTablePlan;
@@ -1539,10 +1540,10 @@ public class ConfigPhysicalPlanSerDeTest {
@Test
public void PreAlterTableColumnDataTypePlanTest() throws IOException {
- final AlterColumnDataTypePlan alterColumnDataTypePlan =
- new AlterColumnDataTypePlan("database1", "table1", "field",
TSDataType.FLOAT);
- final AlterColumnDataTypePlan alterColumnDataTypePlan1 =
- (AlterColumnDataTypePlan)
+ final PreAlterColumnDataTypePlan alterColumnDataTypePlan =
+ new PreAlterColumnDataTypePlan("database1", "table1", "field",
TSDataType.FLOAT);
+ final PreAlterColumnDataTypePlan alterColumnDataTypePlan1 =
+ (PreAlterColumnDataTypePlan)
ConfigPhysicalPlan.Factory.create(alterColumnDataTypePlan.serializeToByteBuffer());
Assert.assertEquals(
alterColumnDataTypePlan.getDatabase(),
alterColumnDataTypePlan1.getDatabase());
@@ -1555,6 +1556,24 @@ public class ConfigPhysicalPlanSerDeTest {
alterColumnDataTypePlan.getNewType(),
alterColumnDataTypePlan1.getNewType());
}
+ @Test
+ public void AlterTableColumnDataTypePlanTest() throws IOException {
+ final AlterColumnDataTypePlan alterColumnDataTypePlan =
+ new AlterColumnDataTypePlan("database1", "table1", "field",
TSDataType.FLOAT);
+ final AlterColumnDataTypePlan alterColumnDataTypePlan1 =
+ (AlterColumnDataTypePlan)
+
ConfigPhysicalPlan.Factory.create(alterColumnDataTypePlan.serializeToByteBuffer());
+ Assert.assertEquals(
+ alterColumnDataTypePlan.getDatabase(),
alterColumnDataTypePlan1.getDatabase());
+ Assert.assertEquals(
+ alterColumnDataTypePlan.getTableName(),
alterColumnDataTypePlan1.getTableName());
+ Assert.assertEquals(
+ alterColumnDataTypePlan.getColumnName(),
alterColumnDataTypePlan1.getColumnName());
+ Assert.assertEquals(alterColumnDataTypePlan.getType(),
alterColumnDataTypePlan1.getType());
+ Assert.assertEquals(
+ alterColumnDataTypePlan.getNewType(),
alterColumnDataTypePlan1.getNewType());
+ }
+
@Test
public void RenameTablePlanTest() throws IOException {
final RenameTablePlan renameTablePlan =
