[fix][zeta] change store finished job info time

chaorongzhi · Sep 1, 2023 · 01035e9 · 01035e9
1 parent dda3cbe
commit 01035e9
Showing 1 changed file with 2 additions and 1 deletion.
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
@@ -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