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);
 

Reply via email to