From 01035e94ac7c008cb74467b9736a3a8e65424f46 Mon Sep 17 00:00:00 2001
From: chaorongzhi <chao_rongzhi3@venustech.com.cn>
Date: Wed, 9 Aug 2023 14:58:59 +0800
Subject: [PATCH] [fix][zeta] change store finished job info time

---
 .../seatunnel/engine/server/master/JobHistoryService.java      | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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 73474ad7761..bc661620325 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
@@ -76,6 +76,7 @@ public class JobHistoryService {
      * finishedJobStateImap key is jobId and value is jobState(json) JobStateData Indicates the
      * status of the job, pipeline, and task
      */
+    // TODO need to limit the amount of storage
     private final IMap<Long, JobState> finishedJobStateImap;
 
     private final IMap<Long, JobMetrics> finishedJobMetricsImap;
@@ -237,7 +238,7 @@ private JobState toJobStateMapper(JobMaster jobMaster, boolean simple) {
     }
 
     public void storeJobInfo(long jobId, JobDAGInfo jobInfo) {
-        finishedJobDAGInfoImap.put(jobId, jobInfo, finishedJobExpireTime, TimeUnit.MINUTES);
+        finishedJobDAGInfoImap.put(jobId, jobInfo);
     }
 
     @AllArgsConstructor