This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch IOTDB-3341 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 10beb843da6915d00f7eb433b2b34ddc15ab8158 Author: JackieTien97 <[email protected]> AuthorDate: Tue May 31 08:41:13 2022 +0800 [IOTDB-3341] Fix timeseries id is not right while doing last query --- .../org/apache/iotdb/db/mpp/plan/planner/LocalExecutionPlanner.java | 6 ++---- 1 file changed, 2 insertions(+), 4 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 b5ee12fd41..73f89cf160 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 @@ -1110,8 +1110,7 @@ public class LocalExecutionPlanner { return null; } } else { // cached last value is satisfied, put it into LastCacheScanOperator - context.addCachedLastValue( - timeValuePair, node.getPlanNodeId(), node.getSeriesPath().getFullPath()); + context.addCachedLastValue(timeValuePair, node.getPlanNodeId(), seriesPath.getFullPath()); return null; } } @@ -1179,8 +1178,7 @@ public class LocalExecutionPlanner { return null; } } else { // cached last value is satisfied, put it into LastCacheScanOperator - context.addCachedLastValue( - timeValuePair, node.getPlanNodeId(), node.getSeriesPath().getFullPath()); + context.addCachedLastValue(timeValuePair, node.getPlanNodeId(), seriesPath.getFullPath()); return null; } }
