Fix job will never cancel success when JobMaster init not complete (#…

…6885)
apache · May 22, 2024 · b533364 · b533364
1 parent 6010460
commit b533364
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...nnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobMaster.java b/...nnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobMaster.java
@@ -180,7 +180,7 @@ public JobMaster(
         this.seaTunnelServer = seaTunnelServer;
     }
 
-    public void init(long initializationTimestamp, boolean restart) throws Exception {
+    public synchronized void init(long initializationTimestamp, boolean restart) throws Exception {
         jobImmutableInformation =
                 nodeEngine.getSerializationService().toObject(jobImmutableInformationData);
         jobCheckpointConfig =
@@ -490,7 +490,7 @@ public Address queryTaskGroupAddress(TaskGroupLocation taskGroupLocation) {
                 "can't find task group address from taskGroupLocation: " + taskGroupLocation);
     }
 
-    public void cancelJob() {
+    public synchronized void cancelJob() {
         physicalPlan.cancelJob();
     }