Update IoTDBConfigNodeReceiver.java

apache · Jan 21, 2025 · 6098091 · 6098091
1 parent 0cb789c
commit 6098091
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/...a/org/apache/iotdb/confignode/manager/pipe/receiver/protocol/IoTDBConfigNodeReceiver.java b/...a/org/apache/iotdb/confignode/manager/pipe/receiver/protocol/IoTDBConfigNodeReceiver.java
@@ -55,6 +55,7 @@
 import org.apache.iotdb.confignode.consensus.request.write.table.CommitDeleteTablePlan;
 import org.apache.iotdb.confignode.consensus.request.write.table.RenameTableColumnPlan;
 import org.apache.iotdb.confignode.consensus.request.write.table.SetTableColumnCommentPlan;
+import org.apache.iotdb.confignode.consensus.request.write.table.SetTableCommentPlan;
 import org.apache.iotdb.confignode.consensus.request.write.table.SetTablePropertiesPlan;
 import org.apache.iotdb.confignode.consensus.request.write.template.CommitSetSchemaTemplatePlan;
 import org.apache.iotdb.confignode.consensus.request.write.template.ExtendSchemaTemplatePlan;
@@ -536,6 +537,14 @@ private TSStatus executePlan(final ConfigPhysicalPlan plan) throws ConsensusExce
                     ((CommitDeleteTablePlan) plan).getTableName(),
                     queryId,
                     true));
+      case SetTableComment:
+        return configManager
+            .getClusterSchemaManager()
+            .setTableComment(
+                ((SetTableCommentPlan) plan).getDatabase(),
+                ((SetTableCommentPlan) plan).getTableName(),
+                ((SetTableCommentPlan) plan).getComment(),
+                true);
       case SetTableColumnComment:
         return configManager
             .getClusterSchemaManager()