(celeborn) branch main updated: [CELEBORN-1792][FOLLOWUP] Add missing break in resumeByPinnedMemory

[nicholasjiang]

This is an automated email from the ASF dual-hosted git repository.

nicholasjiang pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/celeborn.git


The following commit(s) were added to refs/heads/main by this push:
     new fdcc10868 [CELEBORN-1792][FOLLOWUP] Add missing break in 
resumeByPinnedMemory
fdcc10868 is described below

commit fdcc1086894caf6396205e13a79a861653497d0c
Author: liuyang62 <liuyan...@staff.sina.com>
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 <liuyan...@staff.sina.com>
    Signed-off-by: SteNicholas <programg...@163.com>
---
 .../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;
     }
   }