You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by sh...@apache.org on 2017/01/03 06:42:39 UTC
[03/15] kylin git commit: minor,
setEndTime for discarded but finished job
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/sparkcubing-rebase
Commit: 9d3573a661d98c6a56716edc80e667b4050c54da
Parents: 6e4637c
Author: Billy Liu <bi...@apache.org>
Authored: Fri Dec 30 15:55:35 2016 +0800
Committer: Billy Liu <bi...@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);