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
  • Loading branch information
cchung100m committed Jan 21, 2025
1 parent 3bce707 commit 3b45f35
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -720,8 +720,8 @@ public void case6() throws Exception {
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);
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 3b45f35

Please sign in to comment.