Skip to content

Commit

Permalink
Add comment
Browse files Browse the repository at this point in the history
  • Loading branch information
maobaolong committed Jan 8, 2025
1 parent efd894d commit 39ee790
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -131,11 +131,11 @@ public void testReconfigureNodeMax() throws Exception {
assertEquals(5, info.getServerToPartitionRanges().keySet().size());

// case3: recover its value to 10
// Make sure last modification time change
Thread.sleep(1000L);
try (FileWriter fileWriter = new FileWriter(tempConfFilePath)) {
fileWriter.append(CoordinatorConf.COORDINATOR_SHUFFLE_NODES_MAX.key() + " " + 10);
}
Thread.sleep(1000L);
Awaitility.await().timeout(2, TimeUnit.SECONDS).until(() -> nodeMax.get() == 10);
info = shuffleWriteClient.getShuffleAssignments("app1", 0, 10, 1, TAGS, SERVER_NUM + 10, -1);
assertEquals(10, info.getServerToPartitionRanges().keySet().size());
Expand Down

0 comments on commit 39ee790

Please sign in to comment.