This is an automated email from the ASF dual-hosted git repository.

kirs pushed a commit to branch 1.3.7-prepare
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/1.3.7-prepare by this push:
     new 246c6db  [1.3.7-prepare#5776][Improvement][Worker] Improve task 
process status log (#5841)
246c6db is described below

commit 246c6dbc563e52d6a4d0f50bce28fe98d5f42db1
Author: Kirs <[email protected]>
AuthorDate: Wed Jul 28 16:16:38 2021 +0800

    [1.3.7-prepare#5776][Improvement][Worker] Improve task process status log 
(#5841)
    
    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 4baf8af..377d2c8 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;
     }

Reply via email to