[HotFix][zeta]: Fix loss job (#6759) (#6807)

apache · May 9, 2024 · a34d259 · a34d259
1 parent 4660096
commit a34d259
Showing 1 changed file with 7 additions and 6 deletions.
diff --git a/...ine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobHistoryService.java b/...ine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobHistoryService.java
@@ -104,16 +104,17 @@ public JobHistoryService(
         this.finishedJobExpireTime = finishedJobExpireTime;
     }
 
-    // Gets the status of a running and completed job
+    // Gets the status of a running and completed job.
     public String listAllJob() {
         List<JobStatusData> status = new ArrayList<>();
-        Set<Long> runningJonIds =
+        final List<JobState> runningJobStateList =
                 runningJobMasterMap.values().stream()
-                        .map(master -> master.getJobImmutableInformation().getJobId())
-                        .collect(Collectors.toSet());
+                        .map(master -> toJobStateMapper(master, true))
+                        .collect(Collectors.toList());
+        Set<Long> runningJonIds =
+                runningJobStateList.stream().map(JobState::getJobId).collect(Collectors.toSet());
         Stream.concat(
-                        runningJobMasterMap.values().stream()
-                                .map(master -> toJobStateMapper(master, true)),
+                        runningJobStateList.stream(),
                         finishedJobStateImap.values().stream()
                                 .filter(jobState -> !runningJonIds.contains(jobState.getJobId())))
                 .forEach(