Skip to content

Commit 07eb8d5

Browse files
authored
[#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.
1 parent 9d43c1e commit 07eb8d5

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleWithRssClientTest.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -475,6 +475,10 @@ public void testRetryAssgin() throws Throwable {
475475
if (ss.getId().equals(entry.getKey().getId())) {
476476
try {
477477
ss.stopServer();
478+
coordinators.forEach(
479+
c ->
480+
c.getClusterManager()
481+
.addExcludedNodes(Lists.newArrayList(ss.getId())));
478482
} catch (Exception e) {
479483
e.printStackTrace();
480484
}

0 commit comments

Comments
 (0)