This is an automated email from the ASF dual-hosted git repository.

shaofengshi pushed a commit to branch 2.5.x
in repository https://gitbox.apache.org/repos/asf/kylin.git


The following commit(s) were added to refs/heads/2.5.x by this push:
     new e3d9909  KYLIN-3808 fix RestAPI /api/jobs always returns 0 for 
exec_start_time and exec_end_time and exec_interrupt_time fields
e3d9909 is described below

commit e3d9909343c926055ea6a97ab5ea0cc5098f8957
Author: yaozhongqiang <alex...@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 <shaofeng...@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 d8aa711..e014785 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
@@ -496,6 +496,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);
@@ -519,6 +522,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.setDuration(job.getDuration() / 1000);
@@ -547,6 +553,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.setDuration(job.getDuration() / 1000);

Reply via email to