Skip to content

Commit ca2d007

Browse files
try fix oom lolz
1 parent 47348a1 commit ca2d007

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

datafusion/physical-plan/src/aggregates/row_hash.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -635,6 +635,7 @@ impl GroupedHashAggregateStream {
635635
for group_values in &group_by_values {
636636
// calculate the group indices for each input row
637637
let starting_num_groups = self.group_values.len();
638+
self.reservation.try_resize(self.reservation.size() * 2)?;
638639
self.group_values
639640
.intern(group_values, &mut self.current_group_indices)?;
640641
let group_indices = &self.current_group_indices;

0 commit comments

Comments
 (0)