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/incubator-uniffle.git
The following commit(s) were added to refs/heads/master by this push: new c3d8a8048 [MINOR] fix(test): fix flaky test ShuffleServerOnRandomPortTest (#1953) c3d8a8048 is described below commit c3d8a80482f751714f67e31b252f4029c28b004f Author: xianjingfeng <xianjingfeng...@gmail.com> AuthorDate: Thu Jul 25 17:05:20 2024 +0800 [MINOR] fix(test): fix flaky test ShuffleServerOnRandomPortTest (#1953) ### What changes were proposed in this pull request? Fix flaky test ShuffleServerOnRandomPortTest. ### Why are the changes needed? The random port may be 40000. https://github.com/apache/incubator-uniffle/actions/runs/10087508746/job/27891800095?pr=1952 ### Does this PR introduce any user-facing change? No. ### How was this patch tested? CI --- .../java/org/apache/uniffle/test/ShuffleServerOnRandomPortTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleServerOnRandomPortTest.java b/integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleServerOnRandomPortTest.java index c31c338db..eb5cefb94 100644 --- a/integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleServerOnRandomPortTest.java +++ b/integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleServerOnRandomPortTest.java @@ -67,7 +67,7 @@ public class ShuffleServerOnRandomPortTest extends CoordinatorTestBase { CoordinatorTestUtils.waitForRegister(coordinatorClient, 2); Thread.sleep(5000); int actualPort = nettyShuffleServers.get(0).getNettyPort(); - assertTrue(actualPort >= 30000 && actualPort < 40000); + assertTrue(actualPort >= 30000 && actualPort <= 40000); actualPort = nettyShuffleServers.get(1).getNettyPort(); assertTrue(actualPort >= 30000 && actualPort <= 40000); @@ -87,7 +87,7 @@ public class ShuffleServerOnRandomPortTest extends CoordinatorTestBase { CoordinatorTestUtils.waitForRegister(coordinatorClient, 2); Thread.sleep(5000); int actualPort = grpcShuffleServers.get(0).getGrpcPort(); - assertTrue(actualPort >= 30000 && actualPort < 40000); + assertTrue(actualPort >= 30000 && actualPort <= 40000); actualPort = grpcShuffleServers.get(1).getGrpcPort(); assertTrue(actualPort >= 30000 && actualPort <= 40000);