diff --git a/yarn/src/org/apache/hadoop/yarn/rabit/ApplicationMaster.java b/yarn/src/org/apache/hadoop/yarn/rabit/ApplicationMaster.java index 46787ba09..a3b655eb5 100644 --- a/yarn/src/org/apache/hadoop/yarn/rabit/ApplicationMaster.java +++ b/yarn/src/org/apache/hadoop/yarn/rabit/ApplicationMaster.java @@ -217,13 +217,9 @@ public class ApplicationMaster { success = finishedTasks.size() == numTasks; LOG.info("Application completed. Stopping running containers"); diagnostics = "Diagnostics." + ", num_tasks" + this.numTasks - + ", finished=" + this.finishedTasks.size() + ", failed=" - + this.killedTasks.size() + "\n" + this.abortDiagnosis; - if (success) { - nmClient.stop(); - } else { - throw new Exception("Application not successful" + diagnostics); - } + + ", finished=" + this.finishedTasks.size() + ", failed=" + + this.killedTasks.size() + "\n" + this.abortDiagnosis; + nmClient.stop(); LOG.info(diagnostics); } catch (Exception e) { diagnostics = e.toString();