diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-services/hadoop-yarn-services-core/src/main/java/org/apache/hadoop/yarn/service/component/instance/ComponentInstance.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-services/hadoop-yarn-services-core/src/main/java/org/apache/hadoop/yarn/service/component/instance/ComponentInstance.java index 64f35d3..e7994f7 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-services/hadoop-yarn-services-core/src/main/java/org/apache/hadoop/yarn/service/component/instance/ComponentInstance.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-services/hadoop-yarn-services-core/src/main/java/org/apache/hadoop/yarn/service/component/instance/ComponentInstance.java @@ -253,12 +253,17 @@ static void handleComponentInstanceRelaunch( // re-ask the failed container. comp.requestContainers(1); comp.reInsertPendingInstance(compInstance); - LOG.info(compInstance.getCompInstanceId() - + ": {} completed. Reinsert back to pending list and requested " + - "a new container." + System.lineSeparator() + - " exitStatus={}, diagnostics={}.", - event.getContainerId(), event.getStatus().getExitStatus(), - event.getStatus().getDiagnostics()); + String message = compInstance.getCompInstanceId() + ": " + event.getContainerId() + + " completed. Reinsert back to pending list and requested a new container." + System.lineSeparator() + + " exitStatus=" + event.getStatus().getExitStatus() + + ", diagnostics=" + event.getStatus().getDiagnostics(); + + if (event.getStatus().getExitStatus() != 0) { + LOG.error(message); + } + else { + LOG.info(message); + } } else { // When no relaunch, update component's #succeeded/#failed // instances.