You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2022/05/26 13:21:59 UTC
[iotdb] 01/01: Fix Last Query Bug for Aligned
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 <ja...@gmail.com>
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(),