Fix bug of finished judge in HashAggregationOperator (#13842)

apache · Oct 20, 2024 · 46a1335 · 46a1335
1 parent c664a93
commit 46a1335
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...ine/execution/operator/source/relational/aggregation/grouped/HashAggregationOperator.java b/...ine/execution/operator/source/relational/aggregation/grouped/HashAggregationOperator.java
@@ -102,7 +102,7 @@ public ListenableFuture<?> isBlocked() {
 
   @Override
   public boolean hasNext() throws Exception {
-    return !finished;
+    return !finished || retainedTsBlock != null;
   }
 
   @Override
@@ -171,7 +171,7 @@ private void closeAggregationBuilder() {
 
   @Override
   public boolean isFinished() throws Exception {
-    return finished;
+    return finished && retainedTsBlock == null;
   }
 
   @Override