Skip to content

Commit f3c9009

Browse files
authored
Use FairSpillPool for TaskContext with spillable config (#8072)
1 parent 56f6437 commit f3c9009

1 file changed

Lines changed: 6 additions & 2 deletions

File tree

  • datafusion/physical-plan/src/aggregates

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

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1171,6 +1171,7 @@ mod tests {
11711171
AggregateExpr, EquivalenceProperties, PhysicalExpr, PhysicalSortExpr,
11721172
};
11731173

1174+
use datafusion_execution::memory_pool::FairSpillPool;
11741175
use futures::{FutureExt, Stream};
11751176

11761177
// Generate a schema which consists of 5 columns (a, b, c, d, e)
@@ -1271,8 +1272,11 @@ mod tests {
12711272
fn new_spill_ctx(batch_size: usize, max_memory: usize) -> Arc<TaskContext> {
12721273
let session_config = SessionConfig::new().with_batch_size(batch_size);
12731274
let runtime = Arc::new(
1274-
RuntimeEnv::new(RuntimeConfig::default().with_memory_limit(max_memory, 1.0))
1275-
.unwrap(),
1275+
RuntimeEnv::new(
1276+
RuntimeConfig::default()
1277+
.with_memory_pool(Arc::new(FairSpillPool::new(max_memory))),
1278+
)
1279+
.unwrap(),
12761280
);
12771281
let task_ctx = TaskContext::default()
12781282
.with_session_config(session_config)

0 commit comments

Comments
 (0)