From d22f00e2270ef6f91b262d0347f00df8cf06437d Mon Sep 17 00:00:00 2001 From: CalvinKirs Date: Mon, 19 Jul 2021 16:32:12 +0800 Subject: [PATCH] [1.3.7-prepare#5776][Improvement][Worker] Improve task process status log Issue #5741 Pr #5776 --- .../server/worker/task/AbstractCommandExecutor.java | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/AbstractCommandExecutor.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/AbstractCommandExecutor.java index 4baf8af21..377d2c884 100644 --- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/AbstractCommandExecutor.java +++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/worker/task/AbstractCommandExecutor.java @@ -213,12 +213,6 @@ public abstract class AbstractCommandExecutor { // waiting for the run to finish boolean status = process.waitFor(remainTime, TimeUnit.SECONDS); - - logger.info("process has exited, execute path:{}, processId:{} ,exitStatusCode:{}", - taskExecutionContext.getExecutePath(), - processId - , result.getExitStatusCode()); - // if SHELL task exit if (status) { // set appIds @@ -238,6 +232,8 @@ public abstract class AbstractCommandExecutor { result.setExitStatusCode(EXIT_CODE_FAILURE); } + logger.info("process has exited, execute path:{}, processId:{} ,exitStatusCode:{} ,processWaitForStatus:{} ,processExitValue:{}", + taskExecutionContext.getExecutePath(), processId, result.getExitStatusCode(), status, process.exitValue()); return result; } -- GitLab