[Fix][Zeta] Fix pendingJobMasterMap resource leak

hawk9821 · hawk9821 · commit 9f2897a9939d · 2025-09-15T11:00:02.000+08:00
diff --git a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/JobExecutionIT.java b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/JobExecutionIT.java
@@ -130,7 +130,7 @@ public void cancelJobTest() throws Exception {
             Thread.sleep(1000);
             clientJobProxy.cancelJob();
 
-            await().atMost(40000, TimeUnit.MILLISECONDS)
+            await().atMost(20000, TimeUnit.MILLISECONDS)
                     .untilAsserted(
                             () -> {
                                 Assertions.assertTrue(objectCompletableFuture.isDone());
diff --git a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/CoordinatorService.java b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/CoordinatorService.java
@@ -322,9 +322,7 @@ private void pendingJobSchedule() throws InterruptedException {
     }
 
     private void queueRemove(JobMaster jobMaster) {
-        if (pendingJobQueue.contains(jobMaster.getJobId())) {
-            pendingJobQueue.removeById(jobMaster.getJobId());
-        }
+        pendingJobQueue.removeById(jobMaster.getJobId());
     }
 
     private void completeFailJob(JobMaster jobMaster) {

Original file line number	Diff line number	Diff line change
`@@ -322,9 +322,7 @@ private void pendingJobSchedule() throws InterruptedException {`
`322`	`322`	`}`
`323`	`323`
`324`	`324`	`private void queueRemove(JobMaster jobMaster) {`
`325`		`- if (pendingJobQueue.contains(jobMaster.getJobId())) {`
`326`		`- pendingJobQueue.removeById(jobMaster.getJobId());`
`327`		`- }`
	`325`	`+ pendingJobQueue.removeById(jobMaster.getJobId());`
`328`	`326`	`}`
`329`	`327`
`330`	`328`	`private void completeFailJob(JobMaster jobMaster) {`