This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch rc/1.2.2 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 8bc636ac0fc6acfc20aa4fe9d306f135faa3952e Author: HTHou <[email protected]> AuthorDate: Tue Sep 26 19:19:01 2023 +0800 Revert "[IOTDB-6134] Fill statement content in show queries for inner schema fetch" This reverts commit a17799b6feb0a97b3917b1e7713e6455d215b656. --- .../plan/analyze/schema/ClusterSchemaFetchExecutor.java | 14 +++++--------- 1 file changed, 5 insertions(+), 9 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/schema/ClusterSchemaFetchExecutor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/schema/ClusterSchemaFetchExecutor.java index 3bb32279e0a..01d4380f306 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/schema/ClusterSchemaFetchExecutor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/schema/ClusterSchemaFetchExecutor.java @@ -74,21 +74,17 @@ class ClusterSchemaFetchExecutor { } private ExecutionResult executionStatement( - long queryId, Statement statement, MPPQueryContext context) { - - long timeout = context == null ? config.getQueryTimeoutThreshold() : context.getTimeOut(); - String sql = context == null ? "" : "Fetch Schema for " + context.getQueryType(); - if (context != null && context.getQueryType() == QueryType.READ) { - sql += ", " + context.getQueryId() + " : " + context.getSql(); - } + Long queryId, Statement statement, MPPQueryContext context) { return coordinator.execute( statement, queryId, context == null ? null : context.getSession(), - sql, + "", ClusterPartitionFetcher.getInstance(), schemaFetcher, - timeout); + context == null || context.getQueryType().equals(QueryType.WRITE) + ? config.getQueryTimeoutThreshold() + : context.getTimeOut()); } /**
