We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6165887 commit 0cc5ba2Copy full SHA for 0cc5ba2
datafusion/physical-plan/src/repartition/mod.rs
@@ -443,9 +443,7 @@ impl BatchPartitioner {
443
num_partitions,
444
// Distribute starting index evenly based on input partition, number of input partitions and number of partitions
445
// to avoid they all start at partition 0 and heavily skew on the lower partitions
446
- next_idx: (input_partition as f64
447
- * (num_partitions as f64 / num_input_partitions as f64))
448
- as usize
+ next_idx: ((input_partition * num_partitions) / num_input_partitions)
449
% num_partitions,
450
}
451
0 commit comments