Skip to content

Commit 5634cce

Browse files
authored
GroupedHashAggregateStream should register spillable consumer (#8002)
1 parent 06f2475 commit 5634cce

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

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

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -328,7 +328,9 @@ impl GroupedHashAggregateStream {
328328
.collect();
329329

330330
let name = format!("GroupedHashAggregateStream[{partition}]");
331-
let reservation = MemoryConsumer::new(name).register(context.memory_pool());
331+
let reservation = MemoryConsumer::new(name)
332+
.with_can_spill(true)
333+
.register(context.memory_pool());
332334

333335
let group_ordering = agg
334336
.aggregation_ordering

0 commit comments

Comments
 (0)