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 2024/10/20 14:48:28 UTC
(iotdb) branch master updated: Fix bug of finished judge in HashAggregationOperator (#13842)
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 46a13352693 Fix bug of finished judge in HashAggregationOperator (#13842)
46a13352693 is described below
commit 46a13352693d64fab64c77d144062a31374589f6
Author: Weihao Li <60...@users.noreply.github.com>
AuthorDate: Sun Oct 20 22:48:22 2024 +0800
Fix bug of finished judge in HashAggregationOperator (#13842)
---
.../relational/aggregation/grouped/HashAggregationOperator.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/HashAggregationOperator.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/HashAggregationOperator.java
index ee395a64128..fbbb1bad774 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/HashAggregationOperator.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/HashAggregationOperator.java
@@ -102,7 +102,7 @@ public class HashAggregationOperator extends AbstractOperator {
@Override
public boolean hasNext() throws Exception {
- return !finished;
+ return !finished || retainedTsBlock != null;
}
@Override
@@ -171,7 +171,7 @@ public class HashAggregationOperator extends AbstractOperator {
@Override
public boolean isFinished() throws Exception {
- return finished;
+ return finished && retainedTsBlock == null;
}
@Override