This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch QueryImprove in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit cadd8512c534252f9fb97f606122cc922b5571c4 Author: JackieTien97 <[email protected]> AuthorDate: Fri Mar 17 18:31:49 2023 +0800 use partitionLatestFlushedTimeForEachDevice instead of newlyFlushedPartitionLatestFlushedTimeForEachDevice --- .../org/apache/iotdb/db/engine/storagegroup/HashLastFlushTimeMap.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/HashLastFlushTimeMap.java b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/HashLastFlushTimeMap.java index 5c337d4709..dbcfe60f31 100644 --- a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/HashLastFlushTimeMap.java +++ b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/HashLastFlushTimeMap.java @@ -253,7 +253,7 @@ public class HashLastFlushTimeMap implements ILastFlushTimeMap { @Override public List<Long> getAllSatisfiedTimePartitions(String deviceId, Filter timeFilter) { if (deviceId == null) { - return newlyFlushedPartitionLatestFlushedTimeForEachDevice.keySet().stream() + return partitionLatestFlushedTimeForEachDevice.keySet().stream() .filter( stringLongMap -> { long[] startAndEndTime = @@ -263,7 +263,7 @@ public class HashLastFlushTimeMap implements ILastFlushTimeMap { }) .collect(Collectors.toList()); } else { - return newlyFlushedPartitionLatestFlushedTimeForEachDevice.entrySet().stream() + return partitionLatestFlushedTimeForEachDevice.entrySet().stream() .filter( entry -> { long[] startAndEndTime =
