Repository: kylin Updated Branches: refs/heads/yang22-cdh5.7 2ec0d8dbd -> 83a77a634 (forced update)
minor, setEndTime for discarded but finished job Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/5c70af27 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/5c70af27 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/5c70af27 Branch: refs/heads/yang22-cdh5.7 Commit: 5c70af27bb2d56d040bbb82d3c112cd9b880bb4d Parents: 8d9d62b Author: Billy Liu <billy...@apache.org> Authored: Fri Dec 30 15:55:35 2016 +0800 Committer: Billy Liu <billy...@apache.org> Committed: Fri Dec 30 15:56:18 2016 +0800 ---------------------------------------------------------------------- .../org/apache/kylin/job/execution/DefaultChainedExecutable.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/5c70af27/core-job/src/main/java/org/apache/kylin/job/execution/DefaultChainedExecutable.java ---------------------------------------------------------------------- diff --git a/core-job/src/main/java/org/apache/kylin/job/execution/DefaultChainedExecutable.java b/core-job/src/main/java/org/apache/kylin/job/execution/DefaultChainedExecutable.java index 253072e..8bcaaad 100644 --- a/core-job/src/main/java/org/apache/kylin/job/execution/DefaultChainedExecutable.java +++ b/core-job/src/main/java/org/apache/kylin/job/execution/DefaultChainedExecutable.java @@ -127,6 +127,7 @@ public class DefaultChainedExecutable extends AbstractExecutable implements Chai } else if (hasRunning) { mgr.updateJobOutput(getId(), ExecutableState.RUNNING, null, null); } else if (hasDiscarded) { + setEndTime(System.currentTimeMillis()); mgr.updateJobOutput(getId(), ExecutableState.DISCARDED, null, null); } else { mgr.updateJobOutput(getId(), ExecutableState.READY, null, null);
