(incubator-celeborn) branch branch-0.3 updated: [CELEBORN-1124] Exclude workers of shuffle manager remove worker of connect exception primary or replica

[fchen]

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

fchen pushed a commit to branch branch-0.3
in repository https://gitbox.apache.org/repos/asf/incubator-celeborn.git


The following commit(s) were added to refs/heads/branch-0.3 by this push:
     new 85f7f74b4 [CELEBORN-1124] Exclude workers of shuffle manager remove 
worker of connect exception primary or replica
85f7f74b4 is described below

commit 85f7f74b43150fa1cfd1a1c13f0208cdeb72a7ef
Author: SteNicholas <programg...@163.com>
AuthorDate: Mon Nov 13 17:31:44 2023 +0800

    [CELEBORN-1124] Exclude workers of shuffle manager remove worker of connect 
exception primary or replica
    
    ### What changes were proposed in this pull request?
    
    Exclude workers of shuffle manager remove worker of connect exception 
primary or replica.
    
    ### Why are the changes needed?
    
    Exclude workers of shuffle manager should not always remove worker of 
connect exception replica.
    
    ### Does this PR introduce _any_ user-facing change?
    
    No.
    
    ### How was this patch tested?
    
    No.
    
    Closes #2091 from SteNicholas/CELEBORN-1124.
    
    Authored-by: SteNicholas <programg...@163.com>
    Signed-off-by: Fu Chen <cfmcgr...@gmail.com>
    (cherry picked from commit 65fb07e694e81acf4eaaa89c48790209b27d4d01)
    Signed-off-by: Fu Chen <cfmcgr...@gmail.com>
---
 .../src/main/scala/org/apache/celeborn/client/WorkerStatusTracker.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/client/src/main/scala/org/apache/celeborn/client/WorkerStatusTracker.scala 
b/client/src/main/scala/org/apache/celeborn/client/WorkerStatusTracker.scala
index 1a83d2a8f..ef570e787 100644
--- a/client/src/main/scala/org/apache/celeborn/client/WorkerStatusTracker.scala
+++ b/client/src/main/scala/org/apache/celeborn/client/WorkerStatusTracker.scala
@@ -165,7 +165,7 @@ class WorkerStatusTracker(
                 StatusCode.RESERVE_SLOTS_FAILED |
                 StatusCode.PUSH_DATA_CREATE_CONNECTION_FAIL_PRIMARY |
                 StatusCode.PUSH_DATA_CREATE_CONNECTION_FAIL_REPLICA |
-                StatusCode.PUSH_DATA_CONNECTION_EXCEPTION_REPLICA |
+                StatusCode.PUSH_DATA_CONNECTION_EXCEPTION_PRIMARY |
                 StatusCode.PUSH_DATA_CONNECTION_EXCEPTION_REPLICA |
                 StatusCode.PUSH_DATA_TIMEOUT_PRIMARY |
                 StatusCode.PUSH_DATA_TIMEOUT_REPLICA