Skip to content

Commit deb5de3

Browse files
authored
[#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
1 parent 08e7397 commit deb5de3

File tree

1 file changed

+4
-4
lines changed
  • integration-test/common/src/test/java/org/apache/uniffle/test

1 file changed

+4
-4
lines changed

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -378,7 +378,7 @@ public void case1() throws Exception {
378378
registerShuffleServer(testAppId, 3, 2, 2, true);
379379
Roaring64NavigableMap blockIdBitmap = Roaring64NavigableMap.bitmapOf();
380380

381-
// only 1 server is timout, the block sending should success
381+
// only 1 server is timeout, the block sending should success
382382
enableTimeout((MockedShuffleServer) grpcShuffleServers.get(2), 500);
383383

384384
// report result should success
@@ -719,9 +719,9 @@ public void case6() throws Exception {
719719
expectedData,
720720
Lists.newArrayList(shuffleServerInfo2, shuffleServerInfo3, shuffleServerInfo4));
721721

722-
// server 0,1,2 are ok, server 3,4 are timout
723-
enableTimeout((MockedShuffleServer) grpcShuffleServers.get(3), 500);
724-
enableTimeout((MockedShuffleServer) grpcShuffleServers.get(4), 500);
722+
// server 0,1,2 are ok, server 3,4 are timeout
723+
enableTimeout((MockedShuffleServer) grpcShuffleServers.get(3), 2000);
724+
enableTimeout((MockedShuffleServer) grpcShuffleServers.get(4), 2000);
725725

726726
Map<Integer, Set<Long>> partitionToBlockIds = Maps.newHashMap();
727727
partitionToBlockIds.put(0, Sets.newHashSet(blockIdBitmap0.stream().iterator()));

0 commit comments

Comments
 (0)