diff --git a/integration-test/common/src/test/java/org/apache/uniffle/test/CoordinatorReconfigureNodeMaxTest.java b/integration-test/common/src/test/java/org/apache/uniffle/test/CoordinatorReconfigureNodeMaxTest.java index adbebac3ad..ec4796c730 100644 --- a/integration-test/common/src/test/java/org/apache/uniffle/test/CoordinatorReconfigureNodeMaxTest.java +++ b/integration-test/common/src/test/java/org/apache/uniffle/test/CoordinatorReconfigureNodeMaxTest.java @@ -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());