This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch LastOperator in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 97b51bd46b1b3b8e13c35c72b876659ffcfdb127 Author: JackieTien97 <[email protected]> AuthorDate: Thu May 26 21:21:19 2022 +0800 Fix Last Query Bug for Aligned --- .../org/apache/iotdb/db/mpp/plan/planner/LocalExecutionPlanner.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LocalExecutionPlanner.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LocalExecutionPlanner.java index 26d9306095..9e37b44da9 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LocalExecutionPlanner.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/LocalExecutionPlanner.java @@ -1148,7 +1148,7 @@ public class LocalExecutionPlanner { UpdateLastCacheOperator.class.getSimpleName()), lastQueryScan, node.getSeriesPath(), - node.getSeriesPath().getSeriesType(), + node.getSeriesPath().getSchemaList().get(0).getType(), DATA_NODE_SCHEMA_CACHE, context.needUpdateLastCache); } @@ -1163,7 +1163,8 @@ public class LocalExecutionPlanner { AlignedSeriesAggregationScanOperator.class.getSimpleName()); // last_time, last_value - List<Aggregator> aggregators = LastQueryUtil.createAggregators(seriesPath.getSeriesType()); + List<Aggregator> aggregators = + LastQueryUtil.createAggregators(seriesPath.getSchemaList().get(0).getType()); AlignedSeriesAggregationScanOperator seriesAggregationScanOperator = new AlignedSeriesAggregationScanOperator( node.getPlanNodeId(),
