1

liugddx · Jan 16, 2024 · c0af4ca · c0af4ca
1 parent c6391ff
commit c0af4ca
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...nel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterSeaTunnelContainer.java b/...nel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterSeaTunnelContainer.java
@@ -131,7 +131,12 @@ public void startUp() throws Exception {
                                         + server.getFirstMappedPort()
                                         + "/hazelcast/rest/cluster");
         response.then().statusCode(200);
-        Assertions.assertEquals(2, response.jsonPath().getList("members").size());
+        Awaitility.await()
+                .atMost(2, TimeUnit.MINUTES)
+                .untilAsserted(
+                        () ->
+                                Assertions.assertEquals(
+                                        2, response.jsonPath().getList("members").size()));
     }
 
     @Override