Repository: kylin Updated Branches: refs/heads/1.5.4-rc1 7c5c6c1c6 -> ba9d83b98
minor, fix job start/end in diagnosis Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/ba9d83b9 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/ba9d83b9 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/ba9d83b9 Branch: refs/heads/1.5.4-rc1 Commit: ba9d83b982ec4c933dc1f05165040f32cd9f8452 Parents: 7c5c6c1 Author: lidongsjtu <lid...@apache.org> Authored: Sat Sep 10 15:23:43 2016 +0800 Committer: lidongsjtu <lid...@apache.org> Committed: Sat Sep 10 15:23:51 2016 +0800 ---------------------------------------------------------------------- tool/src/main/java/org/apache/kylin/tool/JobInstanceExtractor.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/ba9d83b9/tool/src/main/java/org/apache/kylin/tool/JobInstanceExtractor.java ---------------------------------------------------------------------- diff --git a/tool/src/main/java/org/apache/kylin/tool/JobInstanceExtractor.java b/tool/src/main/java/org/apache/kylin/tool/JobInstanceExtractor.java index 086a84f..ef77c6a 100644 --- a/tool/src/main/java/org/apache/kylin/tool/JobInstanceExtractor.java +++ b/tool/src/main/java/org/apache/kylin/tool/JobInstanceExtractor.java @@ -133,6 +133,8 @@ public class JobInstanceExtractor extends AbstractInfoExtractor { result.setType(CubeBuildTypeEnum.BUILD); result.setStatus(parseToJobStatus(output.getState())); result.setMrWaiting(AbstractExecutable.getExtraInfoAsLong(output, CubingJob.MAP_REDUCE_WAIT_TIME, 0L) / 1000); + result.setExecStartTime(AbstractExecutable.getStartTime(output)); + result.setExecEndTime(AbstractExecutable.getEndTime(output)); result.setDuration(AbstractExecutable.getDuration(AbstractExecutable.getStartTime(output), AbstractExecutable.getEndTime(output)) / 1000); for (int i = 0; i < cubeJob.getTasks().size(); ++i) { AbstractExecutable task = cubeJob.getTasks().get(i);
