From 54d9b3d2d00461d6f43520a23b39cdfb4aa653bd Mon Sep 17 00:00:00 2001 From: zhengdong Date: Fri, 1 Sep 2017 17:58:21 +0800 Subject: [PATCH] KYLIN-2753 Fix for the special case that jobs not really stopped --- .../org/apache/kylin/job/execution/ExecutableManager.java | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) 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 124a5a900..0439dddf6 100755 --- 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 @@ -338,12 +338,13 @@ public class ExecutableManager { break; } } - info = Maps.newHashMap(); final long endTime = job.getEndTime(); - long interruptTime = System.currentTimeMillis() - endTime + job.getInterruptTime(); - info.putAll(getJobOutput(jobId).getInfo()); - info.put(AbstractExecutable.INTERRUPT_TIME, Long.toString(interruptTime)); - info.remove(AbstractExecutable.END_TIME); + if (endTime != 0) { + long interruptTime = System.currentTimeMillis() - endTime + job.getInterruptTime(); + info = Maps.newHashMap(getJobOutput(jobId).getInfo()); + info.put(AbstractExecutable.INTERRUPT_TIME, Long.toString(interruptTime)); + info.remove(AbstractExecutable.END_TIME); + } } updateJobOutput(jobId, ExecutableState.READY, info, null); } -- 2.14.1