You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ni...@apache.org on 2019/08/15 13:34:32 UTC

[kylin] 08/11: KYLIN-1856 Clean up old error in step output immediately after resume job

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

nic pushed a commit to branch 2.6.x
in repository https://gitbox.apache.org/repos/asf/kylin.git

commit 13e8e9be10b9699cdb6fa3b9e37c72d14e3332c0
Author: yaqian.zhang <59...@qq.com>
AuthorDate: Mon Jul 29 16:16:15 2019 +0800

    KYLIN-1856 Clean up old error in step output immediately after resume job
---
 .../src/main/java/org/apache/kylin/job/execution/ExecutableManager.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core-job/src/main/java/org/apache/kylin/job/execution/ExecutableManager.java b/core-job/src/main/java/org/apache/kylin/job/execution/ExecutableManager.java
index e8f2512..90c9873 100644
--- a/core-job/src/main/java/org/apache/kylin/job/execution/ExecutableManager.java
+++ b/core-job/src/main/java/org/apache/kylin/job/execution/ExecutableManager.java
@@ -348,7 +348,7 @@ public class ExecutableManager {
             List<AbstractExecutable> tasks = ((DefaultChainedExecutable) job).getTasks();
             for (AbstractExecutable task : tasks) {
                 if (task.getStatus() == ExecutableState.ERROR || task.getStatus() == ExecutableState.STOPPED) {
-                    updateJobOutput(task.getId(), ExecutableState.READY, null, null);
+                    updateJobOutput(task.getId(), ExecutableState.READY, null, "no output");
                     break;
                 }
             }