diff --git a/app/src/test/java/org/astraea/app/backup/BackupTest.java b/app/src/test/java/org/astraea/app/backup/BackupTest.java index b8cc2219de..ea7df4906a 100644 --- 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()); }