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

dybyte 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 43fe63b1fc [Fix][Zeta] Fix undefined job event timeout constant 
(#11954)
43fe63b1fc is described below

commit 43fe63b1fca52ed41b8cd2303b2aa50cc575fb4e
Author: zhiwei.niu <[email protected]>
AuthorDate: Mon Aug 24 19:50:50 2026 +0800

    [Fix][Zeta] Fix undefined job event timeout constant (#11954)
---
 .../org/apache/seatunnel/engine/server/event/JobStateEventTest.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/event/JobStateEventTest.java
 
b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/event/JobStateEventTest.java
index 1a87671bbf..2c9255ab54 100644
--- 
a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/event/JobStateEventTest.java
+++ 
b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/event/JobStateEventTest.java
@@ -162,7 +162,7 @@ class JobStateEventTest extends AbstractSeaTunnelServerTest 
{
 
         long jobIdFailed = System.currentTimeMillis();
         startJob(jobIdFailed, STREAM_CONF_WITH_ERROR_PATH, false);
-        await().atMost(FAILED_JOB_EVENT_TIMEOUT_SECONDS, TimeUnit.SECONDS)
+        await().atMost(RESTORE_TO_FAILED_TIMEOUT_SECONDS, TimeUnit.SECONDS)
                 .untilAsserted(
                         () ->
                                 Assertions.assertEquals(

Reply via email to