assert input is not done

apache · Jul 19, 2023 · 372196e · 372196e
1 parent 048b5cd
commit 372196e
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/datafusion/core/src/physical_plan/aggregates/row_hash.rs b/datafusion/core/src/physical_plan/aggregates/row_hash.rs
@@ -354,11 +354,8 @@ impl Stream for GroupedHashAggregateStream {
 
                             // If we can begin emitting rows, do so,
                             // otherwise keep consuming input
-                            let to_emit = if self.input_done {
-                                Some(EmitTo::All)
-                            } else {
-                                self.group_ordering.emit_to()
-                            };
+                            assert!(!self.input_done);
+                            let to_emit = self.group_ordering.emit_to();
 
                             if let Some(to_emit) = to_emit {
                                 let batch =