Skip to content

Commit d85bdd0

Browse files
committed
feat: update test to reflect the improvements
1 parent b33cb84 commit d85bdd0

1 file changed

Lines changed: 1 addition & 7 deletions

File tree

datafusion/core/tests/fuzz_cases/spilling_fuzz_in_memory_constrained_env.rs

Lines changed: 1 addition & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -505,13 +505,7 @@ async fn run_sort_preserving_merge_peak_memory_with_spilled_input(
505505
// BatchBuilder needs to hold 3 Record batches simultaneously to merge two
506506
// streams (because a stream can cross a record batch boundary)
507507
// there is also one cursor needed per stream
508-
let mut max_peak = 3 * ipc_batch_size + 2 * cursor_unit + converter_size;
509-
510-
// with round robin enabled, 2 extra cursors live in memory
511-
// see https://github.com/apache/datafusion/issues/23604
512-
if round_robin {
513-
max_peak += 2 * cursor_unit;
514-
};
508+
let max_peak = 3 * ipc_batch_size + 2 * cursor_unit + converter_size;
515509

516510
assert!(
517511
peak_bytes <= max_peak,

0 commit comments

Comments
 (0)