This commit is contained in:
tqchen 2015-03-15 23:19:54 -07:00
parent e552ac401e
commit 3ed9ec808f

View File

@ -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();