This is an automated email from the ASF dual-hosted git repository. hui pushed a commit to branch lmh/GroupByDebug in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit d142da0ecdbafc339854f4bbdfd5ecc1e1a3dbb9 Author: liuminghui233 <[email protected]> AuthorDate: Mon May 30 19:32:00 2022 +0800 fix faulty result in group by query --- .../aggregation/slidingwindow/SmoothQueueSlidingWindowAggregator.java | 1 + 1 file changed, 1 insertion(+) diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/aggregation/slidingwindow/SmoothQueueSlidingWindowAggregator.java b/server/src/main/java/org/apache/iotdb/db/mpp/aggregation/slidingwindow/SmoothQueueSlidingWindowAggregator.java index 0d82e0169d..adfe1528c8 100644 --- a/server/src/main/java/org/apache/iotdb/db/mpp/aggregation/slidingwindow/SmoothQueueSlidingWindowAggregator.java +++ b/server/src/main/java/org/apache/iotdb/db/mpp/aggregation/slidingwindow/SmoothQueueSlidingWindowAggregator.java @@ -39,6 +39,7 @@ public class SmoothQueueSlidingWindowAggregator extends SlidingWindowAggregator protected void evictingExpiredValue() { if (!deque.isEmpty() && !curTimeRange.contains(deque.getLast().getTime())) { this.accumulator.reset(); + deque.clear(); return; } while (!deque.isEmpty() && !curTimeRange.contains(deque.getFirst().getTime())) {
