(incubator-uniffle) branch master updated: [#2333] Improvement: extend the timeout value for QuorumTest#case6 (#2348)

[roryqi]

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

roryqi 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 deb5de309 [#2333] Improvement: extend the timeout value for 
QuorumTest#case6 (#2348)
deb5de309 is described below

commit deb5de309cedd1b879be85d89f8f89e530bb7120
Author: Neo Chien <cchung1...@cs.ccu.edu.tw>
AuthorDate: Sun Jan 26 12:12:57 2025 +0800

    [#2333] Improvement: extend the timeout value for QuorumTest#case6 (#2348)
    
    ### What changes were proposed in this pull request?
    extend the timeout value for QuorumTest#case6
    
    ### Why are the changes needed?
    Fix: #2333
    
    ### Does this PR introduce _any_ user-facing change?
    No.
    
    ### How was this patch tested?
    current UT
---
 .../common/src/test/java/org/apache/uniffle/test/QuorumTest.java  | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/integration-test/common/src/test/java/org/apache/uniffle/test/QuorumTest.java 
b/integration-test/common/src/test/java/org/apache/uniffle/test/QuorumTest.java
index ff0fe3477..88a5c1d26 100644
--- 
a/integration-test/common/src/test/java/org/apache/uniffle/test/QuorumTest.java
+++ 
b/integration-test/common/src/test/java/org/apache/uniffle/test/QuorumTest.java
@@ -378,7 +378,7 @@ public class QuorumTest extends ShuffleReadWriteBase {
     registerShuffleServer(testAppId, 3, 2, 2, true);
     Roaring64NavigableMap blockIdBitmap = Roaring64NavigableMap.bitmapOf();
 
-    // only 1 server is timout, the block sending should success
+    // only 1 server is timeout, the block sending should success
     enableTimeout((MockedShuffleServer) grpcShuffleServers.get(2), 500);
 
     // report result should success
@@ -719,9 +719,9 @@ public class QuorumTest extends ShuffleReadWriteBase {
             expectedData,
             Lists.newArrayList(shuffleServerInfo2, shuffleServerInfo3, 
shuffleServerInfo4));
 
-    // server 0,1,2 are ok, server 3,4 are timout
-    enableTimeout((MockedShuffleServer) grpcShuffleServers.get(3), 500);
-    enableTimeout((MockedShuffleServer) grpcShuffleServers.get(4), 500);
+    // server 0,1,2 are ok, server 3,4 are timeout
+    enableTimeout((MockedShuffleServer) grpcShuffleServers.get(3), 2000);
+    enableTimeout((MockedShuffleServer) grpcShuffleServers.get(4), 2000);
 
     Map<Integer, Set<Long>> partitionToBlockIds = Maps.newHashMap();
     partitionToBlockIds.put(0, 
Sets.newHashSet(blockIdBitmap0.stream().iterator()));