Skip to content

Commit

Permalink
fix fmt.
Browse files Browse the repository at this point in the history
  • Loading branch information
Rachelint committed Sep 27, 2024
1 parent 4c86c61 commit 0b01026
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion datafusion/physical-plan/src/aggregates/row_hash.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1008,7 +1008,9 @@ impl GroupedHashAggregateStream {
// And it is not supported if stream has any spills even in Partial aggregation.
// Although currently spilling is actually not supported in Partial aggregation,
// it is possible to be supported in future, so we also add an assertion for it.
assert!(self.mode == AggregateMode::Partial && self.spill_state.spills.is_empty());
assert!(
self.mode == AggregateMode::Partial && self.spill_state.spills.is_empty()
);
probe.update_state(input_rows, self.group_values.len());
};
}
Expand Down

0 comments on commit 0b01026

Please sign in to comment.