Repository: hadoop Updated Branches: refs/heads/trunk 78902f025 -> 144a55f0e
YARN-8045. Reduce log output from container status calls. Contributed by Craig Condit Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/144a55f0 Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/144a55f0 Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/144a55f0 Branch: refs/heads/trunk Commit: 144a55f0e3ba302327baf2e98d1e07b953dcbbfd Parents: 78902f0 Author: Shane Kumpf <[email protected]> Authored: Fri Sep 14 10:41:55 2018 -0600 Committer: Shane Kumpf <[email protected]> Committed: Fri Sep 14 10:41:55 2018 -0600 ---------------------------------------------------------------------- .../containermanager/ContainerManagerImpl.java | 29 +++++++++++++++++++- 1 file changed, 28 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/144a55f0/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/ContainerManagerImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/ContainerManagerImpl.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/ContainerManagerImpl.java index b89e2dd..27a7c80 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/ContainerManagerImpl.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/main/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/ContainerManagerImpl.java @@ -1474,10 +1474,37 @@ public class ContainerManagerImpl extends CompositeService implements } } ContainerStatus containerStatus = container.cloneAndGetContainerStatus(); - LOG.info("Returning " + containerStatus); + logContainerStatus("Returning ", containerStatus); return containerStatus; } + private void logContainerStatus(String prefix, ContainerStatus status) { + StringBuilder sb = new StringBuilder(); + sb.append(prefix); + sb.append("ContainerStatus: ["); + sb.append("ContainerId: "); + sb.append(status.getContainerId()).append(", "); + sb.append("ExecutionType: "); + sb.append(status.getExecutionType()).append(", "); + sb.append("State: "); + sb.append(status.getState()).append(", "); + sb.append("Capability: "); + sb.append(status.getCapability()).append(", "); + sb.append("Diagnostics: "); + sb.append(LOG.isDebugEnabled() ? status.getDiagnostics() : "..."); + sb.append(", "); + sb.append("ExitStatus: "); + sb.append(status.getExitStatus()).append(", "); + sb.append("IP: "); + sb.append(status.getIPs()).append(", "); + sb.append("Host: "); + sb.append(status.getHost()).append(", "); + sb.append("ContainerSubState: "); + sb.append(status.getContainerSubState()); + sb.append("]"); + LOG.info(sb.toString()); + } + @Private @VisibleForTesting protected void authorizeGetAndStopContainerRequest(ContainerId containerId, --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
