dbg log

Rachelint · Oct 3, 2024 · 6ca93c6 · 6ca93c6
1 parent 72a8c18
commit 6ca93c6
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/datafusion/physical-plan/src/aggregates/row_hash.rs b/datafusion/physical-plan/src/aggregates/row_hash.rs
@@ -588,11 +588,14 @@ impl Stream for GroupedHashAggregateStream {
                                 &group_by_values,
                             )?;
                             if self.skip_partial_aggregation {
+                                dbg!("skip_partial_aggregation");
                                 let states = self.transform_to_states(batch)?;
                                 self.exec_state = ExecutionState::ProducingOutput(states);
                                 // make sure the exec_state just set is not overwritten below
                                 break 'reading_input;
-                            }
+                            } else {
+                                dbg!("not skip_partial_aggregation");
+                            };
                             extract_ok!(self.group_aggregate_batch(
                                 batch,
                                 group_by_values,