fix:Only the DIST_LOAD cmdInfo will be deleted.

Alluxio · Jul 8, 2024 · 674269c · 674269c
1 parent 4c819de
commit 674269c
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/job/server/src/main/java/alluxio/master/job/tracker/CmdJobTracker.java b/job/server/src/main/java/alluxio/master/job/tracker/CmdJobTracker.java
@@ -17,6 +17,7 @@
 import alluxio.conf.PropertyKey;
 import alluxio.exception.ExceptionMessage;
 import alluxio.exception.JobDoesNotExistException;
+import alluxio.grpc.OperationType;
 import alluxio.job.CmdConfig;
 import alluxio.job.cmd.load.LoadCliConfig;
 import alluxio.job.cmd.migrate.MigrateCliConfig;
@@ -304,7 +305,8 @@ private void cleanExpiredJobInfos() {
     for (Map.Entry<Long, CmdInfo> x : mInfoMap.entrySet()) {
       CmdInfo cmdInfo = x.getValue();
       List<Long> cleanedJobsId = new ArrayList<>();
-      if (currentTime - cmdInfo.getJobSubmissionTime() > mTraceRetentionTime) {
+      if (OperationType.DIST_LOAD.equals(cmdInfo.getOperationType())
+              && currentTime - cmdInfo.getJobSubmissionTime() > mTraceRetentionTime) {
         try {
           Status jobStatus = getCmdStatus(cmdInfo.getJobControlId());
           if (jobStatus.isFinished()) {