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
The following commit(s) were added to refs/heads/branch-0.6 by this push:
new 0360c80da [CELEBORN-1792][FOLLOWUP] Add missing break in
resumeByPinnedMemory
0360c80da is described below
commit 0360c80daed234266fb69f7a0a84594a935b148d
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;
}
}
