We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 9a3d9b9 commit 353b11bCopy full SHA for 353b11b
datafusion/physical-plan/src/aggregates/row_hash.rs
@@ -710,6 +710,8 @@ impl Stream for GroupedHashAggregateStream {
710
}
711
712
// Check if we should switch to skip aggregation mode
713
+ // It's important that we do this before we early emit since we've
714
+ // already updated the probe.
715
if let Some(new_state) = self.switch_to_skip_aggregation()? {
716
timer.done();
717
self.exec_state = new_state;
0 commit comments