You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hu...@apache.org on 2022/05/30 11:44:30 UTC
[iotdb] 01/03: fix faulty result in group by query
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 <54...@qq.com>
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())) {