From b2505e3d6f729a9146cb5f4afdb63b72b87f7606 Mon Sep 17 00:00:00 2001 From: tqchen Date: Sun, 15 Mar 2015 23:02:15 -0700 Subject: [PATCH] only stop nm when sucess --- yarn/src/org/apache/hadoop/yarn/rabit/ApplicationMaster.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/yarn/src/org/apache/hadoop/yarn/rabit/ApplicationMaster.java b/yarn/src/org/apache/hadoop/yarn/rabit/ApplicationMaster.java index 20eb0b8b1..f51502018 100644 --- a/yarn/src/org/apache/hadoop/yarn/rabit/ApplicationMaster.java +++ b/yarn/src/org/apache/hadoop/yarn/rabit/ApplicationMaster.java @@ -216,7 +216,9 @@ public class ApplicationMaster { assert (killedTasks.size() + finishedTasks.size() == numTasks); success = finishedTasks.size() == numTasks; LOG.info("Application completed. Stopping running containers"); - nmClient.stop(); + if (success) { + nmClient.stop(); + } diagnostics = "Diagnostics." + ", num_tasks" + this.numTasks + ", finished=" + this.finishedTasks.size() + ", failed=" + this.killedTasks.size() + "\n" + this.abortDiagnosis;