This is an automated email from the ASF dual-hosted git repository. nicholasjiang pushed a commit to branch branch-0.6 in repository https://gitbox.apache.org/repos/asf/celeborn.git
commit 25f9e5282b9857c34ca3da84174e1a74405c0da5 Author: liuyang62 <[email protected]> AuthorDate: Tue Aug 5 20:32:55 2025 +0800 [CELEBORN-1792][FOLLOWUP] Add missing break in resumeByPinnedMemory ### What changes were proposed in this pull request? Add missing break in resumeByPinnedMemory ### Why are the changes needed? Avoid execute `resumePush` twice when resume by pinned memory from `PUSH_AND_REPLICATE_PAUSED` state. ### Does this PR introduce _any_ user-facing change? No ### How was this patch tested? GA and cluster tests. Closes #3407 from Flyangz/bugfix/fix-resumeByPinnedMemory-switch. Authored-by: liuyang62 <[email protected]> Signed-off-by: SteNicholas <[email protected]> (cherry picked from commit fdcc1086894caf6396205e13a79a861653497d0c) Signed-off-by: SteNicholas <[email protected]> --- .../org/apache/celeborn/service/deploy/worker/memory/MemoryManager.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/MemoryManager.java b/worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/MemoryManager.java index 6f4922db0..5b11c58ab 100644 --- a/worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/MemoryManager.java +++ b/worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/MemoryManager.java @@ -597,11 +597,13 @@ public class MemoryManager { getNettyPinnedDirectMemory()); resumeReplicate(); resumePush(); + break; case PUSH_PAUSED: logger.info( "Serving State is PUSH_PAUSED, but resume by lower pinned memory {}", getNettyPinnedDirectMemory()); resumePush(); + break; } }
