diff --git a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/Task.java b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/Task.java index 9b62afc..b1b7cd9 100644 --- a/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/Task.java +++ b/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/Task.java @@ -1449,6 +1449,9 @@ protected void runTaskCleanupTask(TaskUmbilicalProtocol umbilical, void taskCleanup(TaskUmbilicalProtocol umbilical) throws IOException { + if (committer == null) { + return; + } // set phase for this task setPhase(TaskStatus.Phase.CLEANUP); getProgress().setStatus("cleanup");