celeborn/master
Sanskar Modi aceee64c73 [CELEBORN-2018] Support min number of workers selected for shuffle
### What changes were proposed in this pull request?
Support min number of workers to assign slots on for a shuffle.

### Why are the changes needed?

PR https://github.com/apache/celeborn/pull/3039 updated the default value of `celeborn.master.slot.assign.extraSlots` to avoid skew in shuffle stage with less number of reducers. However, it will also affect the stage with large number of reducers, thus not ideal.

We are introducing a new config `celeborn.master.slot.assign.minWorkers` which will ensure that shuffle stages with less number of reducers will not cause load imbalance on few nodes.

### Does this PR introduce _any_ user-facing change?
Yes

### How was this patch tested?
NA

Closes #3297 from s0nskar/min_workers.

Authored-by: Sanskar Modi <sanskarmodi97@gmail.com>
Signed-off-by: Wang, Fei <fwang12@ebay.com>
2025-06-01 08:23:53 -07:00
..
src [CELEBORN-2018] Support min number of workers selected for shuffle 2025-06-01 08:23:53 -07:00
pom.xml [CELEBORN-1994] Introduce disruptor dependency to support asynchronous logging of log4j2 2025-05-13 19:45:51 +08:00