(seatunnel) branch dev updated: [Fix][Zeta] Fix checkpoint barrier trigger test race (#11071)

[shenghang]

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

zhangshenghang 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 73d96a736c [Fix][Zeta] Fix checkpoint barrier trigger test race 
(#11071)
73d96a736c is described below

commit 73d96a736c30a3e11ab98583b7f6f4a17a5434f7
Author: Jast <shengh...@apache.org>
AuthorDate: Tue Jun 16 09:41:01 2026 +0800

    [Fix][Zeta] Fix checkpoint barrier trigger test race (#11071)
---
 .../engine/server/checkpoint/CheckpointBarrierTriggerErrorTest.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointBarrierTriggerErrorTest.java
 
b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointBarrierTriggerErrorTest.java
index ebcf282724..ff80c9a646 100644
--- 
a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointBarrierTriggerErrorTest.java
+++ 
b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointBarrierTriggerErrorTest.java
@@ -51,6 +51,7 @@ public class CheckpointBarrierTriggerErrorTest extends 
AbstractSeaTunnelServerTe
     @Test
     public void testCheckpointBarrierTriggerError()
             throws NoSuchFieldException, IllegalAccessException {
+        COUNTER.set(0);
         long jobId = System.currentTimeMillis();
         startJob(jobId, CONF_PATH);
 
@@ -62,11 +63,10 @@ public class CheckpointBarrierTriggerErrorTest extends 
AbstractSeaTunnelServerTe
                                         JobStatus.RUNNING));
 
         CheckpointManager spiedCheckpointManager = 
spy(getCheckpointManager(jobId));
-        setCheckpointManager(spiedCheckpointManager);
-
         doAnswer(this::mockException)
                 .when(spiedCheckpointManager)
                 
.sendOperationToMemberNode(Mockito.any(CheckpointBarrierTriggerOperation.class));
+        setCheckpointManager(spiedCheckpointManager);
 
         await().atMost(120000, TimeUnit.MILLISECONDS)
                 .untilAsserted(