YARN-5693. Reduce loglevel to Debug in ContainerManagementProtocolProxy and AMRMClientImpl (yufeigu via rkanter)
This commit is contained in:
parent
434c5ea75d
commit
2549ee9d4c
|
@ -455,10 +455,12 @@ public class AMRMClientImpl<T extends ContainerRequest> extends AMRMClient<T> {
|
||||||
protected void populateNMTokens(List<NMToken> nmTokens) {
|
protected void populateNMTokens(List<NMToken> nmTokens) {
|
||||||
for (NMToken token : nmTokens) {
|
for (NMToken token : nmTokens) {
|
||||||
String nodeId = token.getNodeId().toString();
|
String nodeId = token.getNodeId().toString();
|
||||||
if (getNMTokenCache().containsToken(nodeId)) {
|
if (LOG.isDebugEnabled()) {
|
||||||
LOG.info("Replacing token for : " + nodeId);
|
if (getNMTokenCache().containsToken(nodeId)) {
|
||||||
} else {
|
LOG.debug("Replacing token for : " + nodeId);
|
||||||
LOG.info("Received new token for : " + nodeId);
|
} else {
|
||||||
|
LOG.debug("Received new token for : " + nodeId);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
getNMTokenCache().setToken(nodeId, token.getToken());
|
getNMTokenCache().setToken(nodeId, token.getToken());
|
||||||
}
|
}
|
||||||
|
|
|
@ -78,8 +78,11 @@ public class ContainerManagementProtocolProxy {
|
||||||
YarnConfiguration.NM_CLIENT_MAX_NM_PROXIES
|
YarnConfiguration.NM_CLIENT_MAX_NM_PROXIES
|
||||||
+ " (" + maxConnectedNMs + ") can not be less than 0.");
|
+ " (" + 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) {
|
if (maxConnectedNMs > 0) {
|
||||||
cmProxy =
|
cmProxy =
|
||||||
|
|
Loading…
Reference in New Issue