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:58 UTC
[iotdb] branch LastOperator created (now 97b51bd46b)
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch LastOperator
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at 97b51bd46b Fix Last Query Bug for Aligned
This branch includes the following new commits:
new 97b51bd46b Fix Last Query Bug for Aligned
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[iotdb] 01/01: Fix Last Query Bug for Aligned
Posted by ja...@apache.org.
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(),