Skip to content

Commit cb58dc7

Browse files
committed
Clear indices temporary vecs earlier
1 parent 6ec97da commit cb58dc7

File tree

1 file changed

+1
-5
lines changed

1 file changed

+1
-5
lines changed

datafusion/src/physical_plan/hash_aggregate.rs

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -500,6 +500,7 @@ pub(crate) fn group_aggregate_batch(
500500
all_group_indices.extend(std::iter::repeat(*group_index).take(indices.len()));
501501
offset_so_far += indices.len();
502502
offsets.push(offset_so_far);
503+
indices.clear();
503504
}
504505
let batch_indices = batch_indices.finish();
505506

@@ -574,11 +575,6 @@ pub(crate) fn group_aggregate_batch(
574575
Ok(())
575576
}
576577
})
577-
// 2.5
578-
.and({
579-
indices.clear();
580-
Ok(())
581-
})
582578
})?;
583579

584580
for (accumulator_index, accumulator) in accumulation_state

0 commit comments

Comments
 (0)