This is an automated email from the ASF dual-hosted git repository. shuwenwei pushed a commit to branch parallelDispatch in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/parallelDispatch by this push: new a2ba40b65e3 remove other changes a2ba40b65e3 is described below commit a2ba40b65e368467e64cc3dc0aa93fec1c443653 Author: shuwenwei <s13979062...@gmail.com> AuthorDate: Wed Jun 4 10:24:36 2025 +0800 remove other changes --- .../operator/source/relational/LastQueryAggTableScanOperator.java | 3 --- .../iotdb/db/queryengine/plan/planner/plan/node/PlanGraphPrinter.java | 1 - 2 files changed, 4 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/LastQueryAggTableScanOperator.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/LastQueryAggTableScanOperator.java index b078d7f2f34..312294ff8b9 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/LastQueryAggTableScanOperator.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/LastQueryAggTableScanOperator.java @@ -26,7 +26,6 @@ import org.apache.iotdb.db.queryengine.execution.operator.source.relational.aggr import org.apache.iotdb.db.queryengine.execution.operator.source.relational.aggregation.LastByDescAccumulator; import org.apache.iotdb.db.queryengine.execution.operator.source.relational.aggregation.LastDescAccumulator; import org.apache.iotdb.db.queryengine.execution.operator.source.relational.aggregation.TableAggregator; -import org.apache.iotdb.db.queryengine.plan.planner.plan.node.PlanGraphPrinter; import org.apache.iotdb.db.queryengine.plan.relational.metadata.ColumnSchema; import org.apache.iotdb.db.queryengine.plan.relational.metadata.DeviceEntry; import org.apache.iotdb.db.queryengine.plan.relational.metadata.QualifiedObjectName; @@ -97,8 +96,6 @@ public class LastQueryAggTableScanOperator extends AbstractAggTableScanOperator this.hitCachedResults = hitCachedResults; this.dbName = qualifiedObjectName.getDatabaseName(); - this.operatorContext.recordSpecifiedInfo( - PlanGraphPrinter.CACHED_DEVICE_NUMBER, Integer.toString(cachedDeviceEntries.size())); for (int i = 0; i < parameter.tableAggregators.size(); i++) { if (parameter.tableAggregators.get(i).getAccumulator() instanceof LastAccumulator) { lastTimeAggregationIdx = i; diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/PlanGraphPrinter.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/PlanGraphPrinter.java index eaf0d700ba6..3188330fef4 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/PlanGraphPrinter.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/PlanGraphPrinter.java @@ -119,7 +119,6 @@ public class PlanGraphPrinter extends PlanVisitor<List<String>, PlanGraphPrinter private static final String REGION_NOT_ASSIGNED = "Not Assigned"; public static final String DEVICE_NUMBER = "DeviceNumber"; - public static final String CACHED_DEVICE_NUMBER = "CachedDeviceNumber"; public static final String CURRENT_USED_MEMORY = "CurrentUsedMemory"; public static final String MAX_USED_MEMORY = "MaxUsedMemory"; public static final String MAX_RESERVED_MEMORY = "MaxReservedMemory";