fix test: wait for restore finished

opensource4you · Mar 30, 2023 · c2fe8b7 · c2fe8b7
1 parent 5831866
commit c2fe8b7
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/app/src/test/java/org/astraea/app/backup/BackupTest.java b/app/src/test/java/org/astraea/app/backup/BackupTest.java
@@ -54,17 +54,18 @@ void testRestoreDistribution() {
           .run()
           .toCompletableFuture()
           .join();
-      Utils.sleep(Duration.ofSeconds(1));
+      Utils.sleep(Duration.ofSeconds(2));
 
       var clusterInfo = admin.clusterInfo(Set.of(topic1, topic2)).toCompletableFuture().join();
       admin.deleteTopics(Set.of(topic1, topic2)).toCompletableFuture().join();
-      Utils.sleep(Duration.ofSeconds(1));
+      Utils.sleep(Duration.ofSeconds(2));
 
       var backup = new Backup();
       backup.restoreDistribution(clusterInfo, SERVICE.bootstrapServers());
+      Utils.sleep(Duration.ofSeconds(2));
       var restoredClusterInfo =
           admin.clusterInfo(Set.of(topic1, topic2)).toCompletableFuture().join();
-      Utils.sleep(Duration.ofSeconds(1));
+      Utils.sleep(Duration.ofSeconds(2));
 
       Assertions.assertEquals(clusterInfo.replicas(), restoredClusterInfo.replicas());
     }