This is an automated email from the ASF dual-hosted git repository. github-merge-queue[bot] pushed a commit to branch gh-readonly-queue/dev/pr-12980-65ccf3615c18e6f6eae6c0be2457b7d2aeefe009 in repository https://gitbox.apache.org/repos/asf/seatunnel.git
commit bddd3b0e782920fdc784224dd7cf028383969e93 Author: zhiweiniu <[email protected]> AuthorDate: Tue Oct 27 10:40:09 2026 +0000 [Fix][Zeta] Wait for completion callback in task finish test (#12980) --- .../org/apache/seatunnel/engine/server/TaskExecutionServiceTest.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/TaskExecutionServiceTest.java b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/TaskExecutionServiceTest.java index 2ce8e0c022..7b25f61928 100644 --- a/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/TaskExecutionServiceTest.java +++ b/seatunnel-engine/seatunnel-engine-server/src/test/java/org/apache/seatunnel/engine/server/TaskExecutionServiceTest.java @@ -313,13 +313,14 @@ public class TaskExecutionServiceTest extends AbstractSeaTunnelServerTest { jobId, pipeLineId, FLAKE_ID_GENERATOR.newId()), "ts", Lists.newArrayList(testTask1, testTask2))); - completableFuture.whenComplete((unused, throwable) -> futureMark.set(true)); + final CompletableFuture<TaskExecutionState> completionCallback = + completableFuture.whenComplete((unused, throwable) -> futureMark.set(true)); stop.set(true); await().atMost(sleepTime + 10000, TimeUnit.MILLISECONDS) .untilAsserted( () -> { - assertEquals(FINISHED, completableFuture.get().getExecutionState()); + assertEquals(FINISHED, completionCallback.get().getExecutionState()); }); assertTrue(futureMark.get()); }
