Repository: kylin Updated Branches: refs/heads/master 1d4c7bb82 -> 444302b2a
KYLIN-1581 NPE in Job engine when execute MR job Project: http://git-wip-us.apache.org/repos/asf/kylin/repo Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/444302b2 Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/444302b2 Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/444302b2 Branch: refs/heads/master Commit: 444302b2afe05940ec8fed43f437d8cd1ffbf62c Parents: 96bd3c4 Author: shaofengshi <[email protected]> Authored: Wed Apr 13 18:13:42 2016 +0800 Committer: shaofengshi <[email protected]> Committed: Wed Apr 13 18:14:26 2016 +0800 ---------------------------------------------------------------------- .../org/apache/kylin/engine/mr/common/MapReduceExecutable.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kylin/blob/444302b2/engine-mr/src/main/java/org/apache/kylin/engine/mr/common/MapReduceExecutable.java ---------------------------------------------------------------------- diff --git a/engine-mr/src/main/java/org/apache/kylin/engine/mr/common/MapReduceExecutable.java b/engine-mr/src/main/java/org/apache/kylin/engine/mr/common/MapReduceExecutable.java index f9c4673..19d888c 100644 --- a/engine-mr/src/main/java/org/apache/kylin/engine/mr/common/MapReduceExecutable.java +++ b/engine-mr/src/main/java/org/apache/kylin/engine/mr/common/MapReduceExecutable.java @@ -74,7 +74,7 @@ public class MapReduceExecutable extends AbstractExecutable { try { Configuration conf = HadoopUtil.getCurrentConfiguration(); Job job = new Cluster(conf).getJob(JobID.forName(mrJobId)); - if (job.getJobState() == JobStatus.State.FAILED) { + if (job == null || job.getJobState() == JobStatus.State.FAILED) { //remove previous mr job info super.onExecuteStart(executableContext); } else {
