[Fix][Zeta] Fix unnecessary job state update (apache#10132)

dybyte · web-flow · commit 349841e8d2bd · 2025-12-08T18:44:23.000+08:00
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
@@ -300,7 +300,7 @@ public void makeJobFailing(Throwable e) {
         updateJobState(JobStatus.FAILING);
     }
 
-    public void startJob() {
+    public synchronized void startJob() {
         isRunning = true;
         log.info("{} state process is start", getJobFullName());
         updateJobState(JobStatus.SCHEDULED);

Original file line number	Diff line number	Diff line change
`@@ -300,7 +300,7 @@ public void makeJobFailing(Throwable e) {`
`300`	`300`	`updateJobState(JobStatus.FAILING);`
`301`	`301`	`}`
`302`	`302`
`303`		`- public void startJob() {`
	`303`	`+ public synchronized void startJob() {`
`304`	`304`	`isRunning = true;`
`305`	`305`	`log.info("{} state process is start", getJobFullName());`
`306`	`306`	`updateJobState(JobStatus.SCHEDULED);`