[Fix] Fix timeout job (datavane#268) (datavane#270)

winghv · Nov 8, 2023 · b3a81d4 · b3a81d4
1 parent 05f79c5
commit b3a81d4
Showing 1 changed file with 0 additions and 5 deletions.
diff --git a/...nes-server/src/main/java/io/datavines/server/dqc/coordinator/cache/JobExecuteManager.java b/...nes-server/src/main/java/io/datavines/server/dqc/coordinator/cache/JobExecuteManager.java
@@ -404,11 +404,6 @@ public void run(Timeout timeout) throws Exception {
                 return;
             }
 
-            if (this.retryTimes != jobExecutionRequest.getRetryTimes()) {
-                logger.info("jobExecution {} is finished, do nothing...",jobExecutionId);
-                return;
-            }
-
             logger.info("jobExecution {} is timeout, do something",jobExecutionId);
             doKillCommand(jobExecutionId);
         }