Repository: kylin Updated Branches: refs/heads/master a1f4ef433 -> 95eb2ff7a
KYLIN-1879 Fix wrong time result in jobs API Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/170d826b Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/170d826b Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/170d826b Branch: refs/heads/master Commit: 170d826bf2d27e625e1d4e1a9b00149098b16197 Parents: a1f4ef4 Author: lidongsjtu <[email protected]> Authored: Tue Jul 12 18:06:17 2016 +0800 Committer: lidongsjtu <[email protected]> Committed: Tue Jul 12 18:06:26 2016 +0800 ---------------------------------------------------------------------- .../src/main/java/org/apache/kylin/rest/service/JobService.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/170d826b/server-base/src/main/java/org/apache/kylin/rest/service/JobService.java ---------------------------------------------------------------------- diff --git a/server-base/src/main/java/org/apache/kylin/rest/service/JobService.java b/server-base/src/main/java/org/apache/kylin/rest/service/JobService.java index c868264..e4fbc98 100644 --- a/server-base/src/main/java/org/apache/kylin/rest/service/JobService.java +++ b/server-base/src/main/java/org/apache/kylin/rest/service/JobService.java @@ -288,7 +288,9 @@ public class JobService extends BasicService { result.setType(CubeBuildTypeEnum.BUILD); result.setStatus(parseToJobStatus(output.getState())); result.setMrWaiting(AbstractExecutable.getExtraInfoAsLong(output, CubingJob.MAP_REDUCE_WAIT_TIME, 0L) / 1000); - result.setDuration(AbstractExecutable.getDuration(AbstractExecutable.getStartTime(output), AbstractExecutable.getEndTime(output)) / 1000); + result.setExecStartTime(AbstractExecutable.getStartTime(output)); + result.setExecEndTime(AbstractExecutable.getEndTime(output)); + result.setDuration(AbstractExecutable.getDuration(result.getExecStartTime(), result.getExecEndTime()) / 1000); for (int i = 0; i < cubeJob.getTasks().size(); ++i) { AbstractExecutable task = cubeJob.getTasks().get(i); result.addStep(parseToJobStep(task, i, outputs.get(task.getId())));
