(uniffle) branch master updated: [#2439] fix(test): remove shuffleServer from coordinators when it stops (#2440)

[xianjingfeng]

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

xianjingfeng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/uniffle.git


The following commit(s) were added to refs/heads/master by this push:
     new 07eb8d55d [#2439] fix(test): remove shuffleServer from coordinators 
when it stops (#2440)
07eb8d55d is described below

commit 07eb8d55d2d43060819ac280f3d59784b3e454d3
Author: xianjingfeng <xianjingfeng...@gmail.com>
AuthorDate: Fri Apr 11 11:08:25 2025 +0800

    [#2439] fix(test): remove shuffleServer from coordinators when it stops 
(#2440)
    
    ### What changes were proposed in this pull request?
    Remove shuffleServer from coordinators when it stops.
    
    ### Why are the changes needed?
    Fix: #2439
    
    ### Does this PR introduce any user-facing change?
    No.
    
    ### How was this patch tested?
    Repeat it for 100 times.
---
 .../test/java/org/apache/uniffle/test/ShuffleWithRssClientTest.java   | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleWithRssClientTest.java
 
b/integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleWithRssClientTest.java
index bb63370b0..7611fce89 100644
--- 
a/integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleWithRssClientTest.java
+++ 
b/integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleWithRssClientTest.java
@@ -475,6 +475,10 @@ public class ShuffleWithRssClientTest extends 
ShuffleReadWriteBase {
                                 if (ss.getId().equals(entry.getKey().getId())) 
{
                                   try {
                                     ss.stopServer();
+                                    coordinators.forEach(
+                                        c ->
+                                            c.getClusterManager()
+                                                
.addExcludedNodes(Lists.newArrayList(ss.getId())));
                                   } catch (Exception e) {
                                     e.printStackTrace();
                                   }