Skip to content

Commit 43507c3

Browse files
committed
fix
1 parent f2e5d08 commit 43507c3

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

fluss-server/src/test/java/org/apache/fluss/server/testutils/FlussClusterExtension.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -869,6 +869,12 @@ public void waitUntilCoordinatorServerElected() {
869869
() -> zooKeeperClient.getCoordinatorLeaderAddress().isPresent(),
870870
Duration.ofSeconds(10),
871871
"Fail to wait coordinator server elected");
872+
// Sleep 1 second to make sure coordinator server has been started and event processor started.
873+
try {
874+
Thread.sleep(1000);
875+
} catch (InterruptedException e) {
876+
throw new RuntimeException(e);
877+
}
872878
}
873879

874880
// --------------------------------------------------------------------------------------------

0 commit comments

Comments
 (0)