(seatunnel) branch dev updated: [Fix][Zeta] Fix unnecessary job state update (#10132)

[lidongdai]

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

lidongdai 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 349841e8d2 [Fix][Zeta] Fix unnecessary job state update (#10132)
349841e8d2 is described below

commit 349841e8d2bde06dd42b56b07704765dad230e9c
Author: dy102 <132787602+dyb...@users.noreply.github.com>
AuthorDate: Mon Dec 8 19:44:23 2025 +0900

    [Fix][Zeta] Fix unnecessary job state update (#10132)
---
 .../org/apache/seatunnel/engine/server/dag/physical/PhysicalPlan.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalPlan.java
 
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalPlan.java
index bf51595b61..86f1a5947d 100644
--- 
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalPlan.java
+++ 
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalPlan.java
@@ -300,7 +300,7 @@ public class PhysicalPlan {
         updateJobState(JobStatus.FAILING);
     }
 
-    public void startJob() {
+    public synchronized void startJob() {
         isRunning = true;
         log.info("{} state process is start", getJobFullName());
         updateJobState(JobStatus.SCHEDULED);