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;
}