You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2024/09/25 03:18:08 UTC
(iotdb) 03/03: Update Coordinator.java
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 <ro...@apache.org>
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,