This is an automated email from the ASF dual-hosted git repository.
wanghailin 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 a34d25916d [HotFix][zeta]: Fix loss job (#6759) (#6807)
a34d25916d is described below
commit a34d25916dfcf5bcf4a9a9aadbb1856896ae7c19
Author: useheart <[email protected]>
AuthorDate: Thu May 9 10:13:43 2024 +0800
[HotFix][zeta]: Fix loss job (#6759) (#6807)
---
.../seatunnel/engine/server/master/JobHistoryService.java | 13 +++++++------
1 file changed, 7 insertions(+), 6 deletions(-)
diff --git
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobHistoryService.java
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobHistoryService.java
index f3905a9e92..0406bf07c6 100644
---
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobHistoryService.java
+++
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobHistoryService.java
@@ -104,16 +104,17 @@ public class 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(
