kylin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From liy...@apache.org
Subject [1/5] kylin git commit: minor, setEndTime for discarded but finished job [Forced Update!]
Date Fri, 30 Dec 2016 12:07:32 GMT
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 <billyliu@apache.org>
Authored: Fri Dec 30 15:55:35 2016 +0800
Committer: Billy Liu <billyliu@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);


Mime
View raw message