YARN-5693. Reduce loglevel to Debug in ContainerManagementProtocolProxy and AMRMClientImpl (yufeigu via rkanter)
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/2549ee9d Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/2549ee9d Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/2549ee9d Branch: refs/heads/YARN-2915 Commit: 2549ee9d4c4ddd3ebccdebb8623df30c0a8f27d2 Parents: 434c5ea Author: Robert Kanter <rkan...@apache.org> Authored: Fri Sep 30 13:30:55 2016 -0700 Committer: Robert Kanter <rkan...@apache.org> Committed: Fri Sep 30 13:30:55 2016 -0700 ---------------------------------------------------------------------- .../hadoop/yarn/client/api/impl/AMRMClientImpl.java | 10 ++++++---- .../client/api/impl/ContainerManagementProtocolProxy.java | 7 +++++-- 2 files changed, 11 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hadoop/blob/2549ee9d/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/impl/AMRMClientImpl.java ---------------------------------------------------------------------- diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/impl/AMRMClientImpl.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/impl/AMRMClientImpl.java index 6f6bb85..3221661 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/impl/AMRMClientImpl.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/impl/AMRMClientImpl.java @@ -455,10 +455,12 @@ public class AMRMClientImpl<T extends ContainerRequest> extends AMRMClient<T> { protected void populateNMTokens(List<NMToken> nmTokens) { for (NMToken token : nmTokens) { String nodeId = token.getNodeId().toString(); - if (getNMTokenCache().containsToken(nodeId)) { - LOG.info("Replacing token for : " + nodeId); - } else { - LOG.info("Received new token for : " + nodeId); + if (LOG.isDebugEnabled()) { + if (getNMTokenCache().containsToken(nodeId)) { + LOG.debug("Replacing token for : " + nodeId); + } else { + LOG.debug("Received new token for : " + nodeId); + } } getNMTokenCache().setToken(nodeId, token.getToken()); } http://git-wip-us.apache.org/repos/asf/hadoop/blob/2549ee9d/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 b2bce22..c619e8a 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 @@ -78,8 +78,11 @@ public class ContainerManagementProtocolProxy { YarnConfiguration.NM_CLIENT_MAX_NM_PROXIES + " (" + maxConnectedNMs + ") can not be less than 0."); } - LOG.info(YarnConfiguration.NM_CLIENT_MAX_NM_PROXIES + " : " - + maxConnectedNMs); + + if (LOG.isDebugEnabled()) { + LOG.debug(YarnConfiguration.NM_CLIENT_MAX_NM_PROXIES + " : " + + maxConnectedNMs); + } if (maxConnectedNMs > 0) { cmProxy = --------------------------------------------------------------------- To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org
