We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f319058 commit 9711351Copy full SHA for 9711351
1 file changed
datafusion/physical-plan/src/joins/grace_hash_join/stream.rs
@@ -57,7 +57,9 @@ use parking_lot::Mutex;
57
/// prevent explosive fan-out.
58
const MAX_REPARTITION_PARTITIONS: usize = 256;
59
/// Upper bound for concurrent spill chunk read-ahead when loading partitions.
60
-const SPILL_READAHEAD_BYTES: usize = 64 * 1024 * 1024;
+/// Use a generous cap to keep IO saturated while staying well below the
61
+/// per-partition memory budget.
62
+const SPILL_READAHEAD_BYTES: usize = 512 * 1024 * 1024;
63
/// Below this size we avoid further repartitioning to keep file counts under control.
64
const MIN_REPARTITION_BYTES: usize = 16 * 1024 * 1024;
65
0 commit comments