This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch pipe-table-model-2 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 5d3c57bc8de00cc26a91dd727b5f7d730875ea46 Author: Steve Yurong Su <[email protected]> AuthorDate: Wed Sep 25 11:17:52 2024 +0800 Update Coordinator.java --- .../main/java/org/apache/iotdb/db/queryengine/plan/Coordinator.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/Coordinator.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/Coordinator.java index a86dfe1dacf..c8358b4f740 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/Coordinator.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/Coordinator.java @@ -54,6 +54,7 @@ import org.apache.iotdb.db.queryengine.plan.relational.sql.ast.DescribeTable; import org.apache.iotdb.db.queryengine.plan.relational.sql.ast.DropDB; import org.apache.iotdb.db.queryengine.plan.relational.sql.ast.DropTable; import org.apache.iotdb.db.queryengine.plan.relational.sql.ast.Flush; +import org.apache.iotdb.db.queryengine.plan.relational.sql.ast.PipeStatement; import org.apache.iotdb.db.queryengine.plan.relational.sql.ast.SetConfiguration; import org.apache.iotdb.db.queryengine.plan.relational.sql.ast.SetProperties; import org.apache.iotdb.db.queryengine.plan.relational.sql.ast.ShowCluster; @@ -330,7 +331,8 @@ public class Coordinator { || statement instanceof ShowDataNodes || statement instanceof ShowConfigNodes || statement instanceof Flush - || statement instanceof SetConfiguration) { + || statement instanceof SetConfiguration + || statement instanceof PipeStatement) { return new ConfigExecution( queryContext, null,
