celeborn icon indicating copy to clipboard operation
celeborn copied to clipboard
verified publisher icon apache

[CELEBORN-1361] MaxInFlightPerWorker should use the value provided by PushStrategy

Open mcdull-zhang opened this issue 2 years ago • 1 comments

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?

mcdull-zhang avatar Mar 29 '24 12:03 mcdull-zhang

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.

github-actions[bot] avatar May 15 '24 08:05 github-actions[bot]

Thanks! Merging to main(v0.5.0)

waitinfuture avatar May 16 '24 11:05 waitinfuture