This is an automated email from the ASF dual-hosted git repository. ebadger pushed a commit to branch branch-2.8 in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/branch-2.8 by this push: new 829afac YARN-8045. Reduce log output from container status calls. Contributed by Craig Condit 829afac is described below commit 829afaca9cd4dbf71032ef5746db86e925d10c25 Author: Eric Badger <ebad...@verizonmedia.com> AuthorDate: Wed Aug 7 14:51:54 2019 +0000 YARN-8045. Reduce log output from container status calls. Contributed by Craig Condit --- .../containermanager/ContainerManagerImpl.java | 21 ++++++++++++++++++++- 1 file changed, 20 insertions(+), 1 deletion(-) 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 a46ea12..c692eb4 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 @@ -1257,10 +1257,29 @@ 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("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("]"); + LOG.info(sb.toString()); + } + @Private @VisibleForTesting protected void authorizeGetAndStopContainerRequest(ContainerId containerId, --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org