YARN-4115. Reduce loglevel of ContainerManagementProtocolProxy to Debug (adhoot via rkanter)
(cherry picked from commit b84fb41bb6ca2d69153cf5bd61f88492538ee713) Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/d07eef8c Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/d07eef8c Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/d07eef8c Branch: refs/heads/branch-2 Commit: d07eef8c871f77a96f9febe9f90be9350bb6d70c Parents: d732c7b Author: Robert Kanter <[email protected]> Authored: Fri Sep 11 11:41:39 2015 -0700 Committer: Robert Kanter <[email protected]> Committed: Fri Sep 11 11:46:35 2015 -0700 ---------------------------------------------------------------------- hadoop-yarn-project/CHANGES.txt | 3 +++ .../api/impl/ContainerManagementProtocolProxy.java | 14 ++++++++++---- 2 files changed, 13 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/d07eef8c/hadoop-yarn-project/CHANGES.txt ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/CHANGES.txt b/hadoop-yarn-project/CHANGES.txt index 5bba479..1ad6570 100644 --- a/hadoop-yarn-project/CHANGES.txt +++ b/hadoop-yarn-project/CHANGES.txt @@ -766,6 +766,9 @@ Release 2.8.0 - UNRELEASED YARN-4106. NodeLabels for NM in distributed mode is not updated even after clusterNodelabel addition in RM. (Bibin A Chundatt via wangda) + YARN-4115. Reduce loglevel of ContainerManagementProtocolProxy to Debug + (adhoot via rkanter) + Release 2.7.2 - UNRELEASED INCOMPATIBLE CHANGES http://git-wip-us.apache.org/repos/asf/hadoop/blob/d07eef8c/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/impl/ContainerManagementProtocolProxy.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/impl/ContainerManagementProtocolProxy.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/impl/ContainerManagementProtocolProxy.java index 94ebf0d..b2bce22 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/impl/ContainerManagementProtocolProxy.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/impl/ContainerManagementProtocolProxy.java @@ -106,8 +106,10 @@ public class ContainerManagementProtocolProxy { while (proxy != null && !proxy.token.getIdentifier().equals( nmTokenCache.getToken(containerManagerBindAddr).getIdentifier())) { - LOG.info("Refreshing proxy as NMToken got updated for node : " - + containerManagerBindAddr); + if (LOG.isDebugEnabled()) { + LOG.debug("Refreshing proxy as NMToken got updated for node : " + + containerManagerBindAddr); + } // Token is updated. check if anyone has already tried closing it. if (!proxy.scheduledForClose) { // try closing the proxy. Here if someone is already using it @@ -187,7 +189,9 @@ public class ContainerManagementProtocolProxy { ContainerManagementProtocolProxyData proxy) { proxy.activeCallers--; if (proxy.scheduledForClose && proxy.activeCallers < 0) { - LOG.info("Closing proxy : " + proxy.containerManagerBindAddr); + if (LOG.isDebugEnabled()) { + LOG.debug("Closing proxy : " + proxy.containerManagerBindAddr); + } cmProxy.remove(proxy.containerManagerBindAddr); try { rpc.stopProxy(proxy.getContainerManagementProtocol(), conf); @@ -257,7 +261,9 @@ public class ContainerManagementProtocolProxy { final InetSocketAddress cmAddr = NetUtils.createSocketAddr(containerManagerBindAddr); - LOG.info("Opening proxy : " + containerManagerBindAddr); + if (LOG.isDebugEnabled()) { + LOG.debug("Opening proxy : " + containerManagerBindAddr); + } // the user in createRemoteUser in this context has to be ContainerID UserGroupInformation user = UserGroupInformation.createRemoteUser(containerId
