[CELEBORN-2063] Parallelize the create partition writer in handleReserveSlots to speed up the reserveSlots RPC process time
What changes were proposed in this pull request?
Parallelize the create partition writer in handleReserveSlots to speed up the reserveSlots RPC process time。
Why are the changes needed?
The creation of partition writer in handleReserveSlots could use parallelize way to speed up the reserveSlots RPC process time.
Does this PR introduce any user-facing change?
Introduce celeborn.worker.writer.create.parallel.enabled, celeborn.worker.writer.create.parallel.threads and eleborn.worker.writer.create.parallel.timeout to config parallelize the creation of file writer.
How was this patch tested?
CI.
Ping @turboFei, @RexXiong, @FMX.
Ping @RexXiong, @turboFei, @zaynt4606. I have addressed above comments.
Plz share some stats about this PR. I was wondering if this PR is helpful for the Spark job's e2e time.
This PR is stale because it has been open 20 days with no activity. Remove stale label or comment or this will be closed in 10 days.
This PR is stale because it has been open 20 days with no activity. Remove stale label or comment or this will be closed in 10 days.