(seatunnel) branch dev updated: [Fix][E2E] Stabilize flaky engine tests (#11457)

[lidongdai]

This is an automated email from the ASF dual-hosted git repository.

davidzollo pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new b994136e9c [Fix][E2E] Stabilize flaky engine tests (#11457)
b994136e9c is described below

commit b994136e9c3d0466f1a10412e103059fce814d67
Author: zhiwei.niu <zniu70...@gmail.com>
AuthorDate: Sun Jul 19 17:39:59 2026 +0800

    [Fix][E2E] Stabilize flaky engine tests (#11457)
---
 .../org/apache/seatunnel/engine/e2e/ClusterFaultToleranceIT.java | 2 +-
 .../seatunnel/engine/client/SeaTunnelEngineClusterRoleTest.java  | 9 +++++----
 2 files changed, 6 insertions(+), 5 deletions(-)

diff --git 
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceIT.java
 
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceIT.java
index f7e1e12c78..675d89279e 100644
--- 
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceIT.java
+++ 
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/ClusterFaultToleranceIT.java
@@ -918,7 +918,7 @@ public class ClusterFaultToleranceIT {
             newClientJobProxy.cancelJob();
             Awaitility.await()
                     .pollDelay(2000, TimeUnit.MILLISECONDS)
-                    .atMost(60000, TimeUnit.MILLISECONDS)
+                    .atMost(300000, TimeUnit.MILLISECONDS)
                     .pollInterval(2000, TimeUnit.MILLISECONDS)
                     .untilAsserted(
                             () -> {
diff --git 
a/seatunnel-engine/seatunnel-engine-client/src/test/java/org/apache/seatunnel/engine/client/SeaTunnelEngineClusterRoleTest.java
 
b/seatunnel-engine/seatunnel-engine-client/src/test/java/org/apache/seatunnel/engine/client/SeaTunnelEngineClusterRoleTest.java
index 82f63ae9d8..0b12e644d5 100644
--- 
a/seatunnel-engine/seatunnel-engine-client/src/test/java/org/apache/seatunnel/engine/client/SeaTunnelEngineClusterRoleTest.java
+++ 
b/seatunnel-engine/seatunnel-engine-client/src/test/java/org/apache/seatunnel/engine/client/SeaTunnelEngineClusterRoleTest.java
@@ -487,10 +487,11 @@ public class SeaTunnelEngineClusterRoleTest {
                     .untilAsserted(
                             () -> {
                                 String status = jobClient.getJobStatus(jobId);
-                                Assertions.assertEquals(
-                                        "CANCELED",
-                                        status,
-                                        "Expected terminal state but was: " + 
status);
+                                Assertions.assertTrue(
+                                        
JobStatus.CANCELING.name().equals(status)
+                                                || 
JobStatus.CANCELED.name().equals(status),
+                                        "Expected job status to be CANCELING 
or CANCELED, but got "
+                                                + status);
                             });
         } finally {
             if (hazelcastClient != null) {