From e949f6681f34f83a75e852bdfd8a57b71aa60cbb Mon Sep 17 00:00:00 2001 From: kangkaisen Date: Thu, 29 Jun 2017 20:25:31 +0800 Subject: [PATCH] KYLIN-2707 Fix NPE in JobInfoConverter --- .../java/org/apache/kylin/engine/mr/common/JobInfoConverter.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/engine-mr/src/main/java/org/apache/kylin/engine/mr/common/JobInfoConverter.java b/engine-mr/src/main/java/org/apache/kylin/engine/mr/common/JobInfoConverter.java index c465e3f78..ec5aef1f0 100644 --- a/engine-mr/src/main/java/org/apache/kylin/engine/mr/common/JobInfoConverter.java +++ b/engine-mr/src/main/java/org/apache/kylin/engine/mr/common/JobInfoConverter.java @@ -63,11 +63,16 @@ public class JobInfoConverter { } public static JobInstance.JobStep parseToJobStep(AbstractExecutable task, int i, Output stepOutput) { - Preconditions.checkNotNull(stepOutput); JobInstance.JobStep result = new JobInstance.JobStep(); result.setId(task.getId()); result.setName(task.getName()); result.setSequenceID(i); + + if (stepOutput == null) { + result.setStatus(JobStepStatusEnum.ERROR); + return result; + } + result.setStatus(parseToJobStepStatus(stepOutput.getState())); for (Map.Entry entry : stepOutput.getExtra().entrySet()) { if (entry.getKey() != null && entry.getValue() != null) { -- 2.11.0 (Apple Git-81)