This is an automated email from the ASF dual-hosted git repository.
zhengchenyu pushed a commit to branch branch-0.9
in repository https://gitbox.apache.org/repos/asf/incubator-uniffle.git
The following commit(s) were added to refs/heads/branch-0.9 by this push:
new 8ce0b4053 [MINOR] fix(test): fix flaky test
ShuffleServerOnRandomPortTest (#1953)
8ce0b4053 is described below
commit 8ce0b405312b15aecc84a2aac454690e82bc965b
Author: xianjingfeng <[email protected]>
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);