Repository: kylin Updated Branches: refs/heads/master 6e4637c98 -> 9d3573a66
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/9d3573a6 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/9d3573a6 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/9d3573a6 Branch: refs/heads/master Commit: 9d3573a661d98c6a56716edc80e667b4050c54da Parents: 6e4637c 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:55:48 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/9d3573a6/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);
