-
Notifications
You must be signed in to change notification settings - Fork 361
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[CELEBORN-1725][FOLLOWUP] Optimize isAllMapTasksEnd
performance
#2959
Conversation
client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks! I think this code fragment could be polished too . https://github.com/apache/celeborn/blob/main/worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Controller.scala#L455-L466
You can add a new PR to fix all similar code snippets. There are still some more |
8c79f5b
to
b065492
Compare
2c50c20
to
e03ae05
Compare
Ok, thx |
b065492
to
d9012d1
Compare
Thanks for the suggestion, will address it in CELEBORN-1753 for |
e5b3c59
to
c1acead
Compare
client/src/main/scala/org/apache/celeborn/client/ClientUtils.scala
Outdated
Show resolved
Hide resolved
### What changes were proposed in this pull request? Followup for #2905, using the same logic to optimize `isAllMapTasksEnd` method. ### Why are the changes needed? Address comments: #2905 (review) ### Does this PR introduce _any_ user-facing change? No. ### How was this patch tested? Same logic with #2905 Closes #2959 from turboFei/celeborn_1725_follow. Authored-by: Wang, Fei <[email protected]> Signed-off-by: Shuang <[email protected]> (cherry picked from commit c84733f) Signed-off-by: Shuang <[email protected]>
Followup for #2905, using the same logic to optimize `isAllMapTasksEnd` method. Address comments: #2905 (review) No. Same logic with #2905 Closes #2959 from turboFei/celeborn_1725_follow. Authored-by: Wang, Fei <[email protected]> Signed-off-by: Shuang <[email protected]> (cherry picked from commit c84733f) Signed-off-by: Shuang <[email protected]>
Thanks, merge to main(V0.6.0) and branch-0.5(v0.5.3) and branch-0.4(v0.4.3) |
What changes were proposed in this pull request?
Followup for #2905,
using the same logic to optimize
isAllMapTasksEnd
method.Why are the changes needed?
Address comments: #2905 (review)
Does this PR introduce any user-facing change?
No.
How was this patch tested?
Same logic with #2905