celeborn/client
mcdull-zhang 8875f20e72 [CELEBORN-1361] MaxInFlightPerWorker should use the value provided by PushStrategy
### What changes were proposed in this pull request?
The data push thread should first send requests to workers that are not under pressure.
Use PushStrategy's `currentMaxReqsInFlight` to better filter requests.

### Why are the changes needed?
Prevent blocking other requests

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

### How was this patch tested?

Closes #2432 from mcdull-zhang/CELEBORN-1361.

Authored-by: mcdull-zhang <work4dong@163.com>
Signed-off-by: zky.zhoukeyong <zky.zhoukeyong@alibaba-inc.com>
2024-05-16 19:47:04 +08:00
..
src [CELEBORN-1361] MaxInFlightPerWorker should use the value provided by PushStrategy 2024-05-16 19:47:04 +08:00
pom.xml [MINOR] Unifiy license format of pom.xml 2024-03-21 14:34:49 +08:00