[kylin] branch main updated: Job duration may become negative after the job resumed from error or paused status

[zhangzc]

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

zhangzc pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/kylin.git


The following commit(s) were added to refs/heads/main by this push:
     new 3a0aadf  Job duration may become negative after the job resumed from 
error or paused status
3a0aadf is described below

commit 3a0aadf785d3ff6fd1e3393f79d830527c1cbeec
Author: yaqian.zhang <598593...@qq.com>
AuthorDate: Wed Aug 11 17:16:16 2021 +0800

    Job duration may become negative after the job resumed from error or paused 
status
---
 .../src/main/java/org/apache/kylin/job/execution/ExecutableManager.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/core-job/src/main/java/org/apache/kylin/job/execution/ExecutableManager.java 
b/core-job/src/main/java/org/apache/kylin/job/execution/ExecutableManager.java
index 2643b86..66b17f5 100644
--- 
a/core-job/src/main/java/org/apache/kylin/job/execution/ExecutableManager.java
+++ 
b/core-job/src/main/java/org/apache/kylin/job/execution/ExecutableManager.java
@@ -570,6 +570,7 @@ public class ExecutableManager {
             if (endTime != 0) {
                 long interruptTime = System.currentTimeMillis() - endTime + 
job.getInterruptTime();
                 info = Maps.newHashMap(getJobOutput(jobId).getInfo());
+                
getJobOutput(jobId).getInfo().remove(AbstractExecutable.END_TIME);
                 info.put(AbstractExecutable.INTERRUPT_TIME, 
Long.toString(interruptTime));
                 info.remove(AbstractExecutable.END_TIME);
             }