Fix flaky test for CoordinatorReconfigureNodeMaxTest#testReconfigureN…

…odeMax
apache · Jan 5, 2025 · efd894d · efd894d
1 parent 3b0521a
commit efd894d
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...-test/common/src/test/java/org/apache/uniffle/test/CoordinatorReconfigureNodeMaxTest.java b/...-test/common/src/test/java/org/apache/uniffle/test/CoordinatorReconfigureNodeMaxTest.java
@@ -131,9 +131,11 @@ public void testReconfigureNodeMax() throws Exception {
     assertEquals(5, info.getServerToPartitionRanges().keySet().size());
 
     // case3: recover its value to 10
+    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());