Browse Source

Merge pull request #595 from lgcareer/branch-1.0.2

The task timeout need deletes the child process
pull/2/head
lgcareer 5 years ago committed by GitHub
parent
commit
667fd722b0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
  1. 7
      escheduler-server/src/main/java/cn/escheduler/server/worker/task/AbstractCommandExecutor.java

7
escheduler-server/src/main/java/cn/escheduler/server/worker/task/AbstractCommandExecutor.java

@ -162,7 +162,12 @@ public abstract class AbstractCommandExecutor {
exitStatusCode = updateState(processDao, exitStatusCode, pid, taskInstId);
} else {
cancelApplication();
TaskInstance taskInstance = processDao.findTaskInstanceById(taskInstId);
if (taskInstance == null) {
logger.error("task instance id:{} not exist", taskInstId);
} else {
ProcessUtils.kill(taskInstance);
}
exitStatusCode = -1;
logger.warn("process timeout, work dir:{}, pid:{}", taskDir, pid);
}

Loading…
Cancel
Save