Skip to content

Commit

Permalink
[#2333] Improvement: extend the timeout value for QuorumTest#case6 (#…
Browse files Browse the repository at this point in the history
…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
  • Loading branch information
cchung100m authored Jan 26, 2025
1 parent 08e7397 commit deb5de3
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -378,7 +378,7 @@ public void case1() throws Exception {
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
Expand Down Expand Up @@ -719,9 +719,9 @@ public void case6() throws Exception {
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()));
Expand Down

0 comments on commit deb5de3

Please sign in to comment.