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 2019/03/06 06:12:39 UTC
[kylin] branch 2.6.x updated: KYLIN-3808 fix RestAPI /api/jobs
always returns 0 for exec_start_time and exec_end_time and
exec_interrupt_time fields
This is an automated email from the ASF dual-hosted git repository.
shaofengshi pushed a commit to branch 2.6.x
in repository https://gitbox.apache.org/repos/asf/kylin.git
The following commit(s) were added to refs/heads/2.6.x by this push:
new 501951c KYLIN-3808 fix RestAPI /api/jobs always returns 0 for exec_start_time and exec_end_time and exec_interrupt_time fields
501951c is described below
commit 501951c9a8e09038c529656a315d6303c553f6bf
Author: yaozhongqiang <al...@163.com>
AuthorDate: Tue Mar 5 16:41:54 2019 +0800
KYLIN-3808 fix RestAPI /api/jobs always returns 0 for exec_start_time and exec_end_time and exec_interrupt_time fields
Signed-off-by: shaofengshi <sh...@apache.org>
---
.../src/main/java/org/apache/kylin/rest/service/JobService.java | 9 +++++++++
1 file changed, 9 insertions(+)
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 46feea0..4f15d9e 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
@@ -485,6 +485,9 @@ public class JobService extends BasicService implements InitializingBean {
result.setLastModified(cubeJob.getLastModified());
result.setSubmitter(cubeJob.getSubmitter());
result.setUuid(cubeJob.getId());
+ result.setExecStartTime(cubeJob.getStartTime());
+ result.setExecEndTime(cubeJob.getEndTime());
+ result.setExecInterruptTime(cubeJob.getInterruptTime());
result.setType(CubeBuildTypeEnum.BUILD);
result.setStatus(JobInfoConverter.parseToJobStatus(job.getStatus()));
result.setMrWaiting(cubeJob.getMapReduceWaitTime() / 1000);
@@ -509,6 +512,9 @@ public class JobService extends BasicService implements InitializingBean {
result.setLastModified(job.getLastModified());
result.setSubmitter(job.getSubmitter());
result.setUuid(job.getId());
+ result.setExecStartTime(job.getStartTime());
+ result.setExecEndTime(job.getEndTime());
+ result.setExecInterruptTime(job.getInterruptTime());
result.setType(CubeBuildTypeEnum.BUILD);
result.setStatus(JobInfoConverter.parseToJobStatus(job.getStatus()));
result.setBuildInstance(AbstractExecutable.getBuildInstance(output));
@@ -539,6 +545,9 @@ public class JobService extends BasicService implements InitializingBean {
result.setLastModified(job.getLastModified());
result.setSubmitter(job.getSubmitter());
result.setUuid(job.getId());
+ result.setExecStartTime(job.getStartTime());
+ result.setExecEndTime(job.getEndTime());
+ result.setExecInterruptTime(job.getInterruptTime());
result.setType(CubeBuildTypeEnum.CHECKPOINT);
result.setStatus(JobInfoConverter.parseToJobStatus(job.getStatus()));
result.setBuildInstance(AbstractExecutable.getBuildInstance(output));