YARN-4115. Reduce loglevel of ContainerManagementProtocolProxy to Debug (adhoot via rkanter)
This commit is contained in:
parent
15a557fcfe
commit
b84fb41bb6
|
@ -818,6 +818,9 @@ Release 2.8.0 - UNRELEASED
|
||||||
YARN-4106. NodeLabels for NM in distributed mode is not updated even after
|
YARN-4106. NodeLabels for NM in distributed mode is not updated even after
|
||||||
clusterNodelabel addition in RM. (Bibin A Chundatt via wangda)
|
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
|
Release 2.7.2 - UNRELEASED
|
||||||
|
|
||||||
INCOMPATIBLE CHANGES
|
INCOMPATIBLE CHANGES
|
||||||
|
|
|
@ -106,8 +106,10 @@ public class ContainerManagementProtocolProxy {
|
||||||
while (proxy != null
|
while (proxy != null
|
||||||
&& !proxy.token.getIdentifier().equals(
|
&& !proxy.token.getIdentifier().equals(
|
||||||
nmTokenCache.getToken(containerManagerBindAddr).getIdentifier())) {
|
nmTokenCache.getToken(containerManagerBindAddr).getIdentifier())) {
|
||||||
LOG.info("Refreshing proxy as NMToken got updated for node : "
|
if (LOG.isDebugEnabled()) {
|
||||||
+ containerManagerBindAddr);
|
LOG.debug("Refreshing proxy as NMToken got updated for node : "
|
||||||
|
+ containerManagerBindAddr);
|
||||||
|
}
|
||||||
// Token is updated. check if anyone has already tried closing it.
|
// Token is updated. check if anyone has already tried closing it.
|
||||||
if (!proxy.scheduledForClose) {
|
if (!proxy.scheduledForClose) {
|
||||||
// try closing the proxy. Here if someone is already using it
|
// try closing the proxy. Here if someone is already using it
|
||||||
|
@ -187,7 +189,9 @@ public class ContainerManagementProtocolProxy {
|
||||||
ContainerManagementProtocolProxyData proxy) {
|
ContainerManagementProtocolProxyData proxy) {
|
||||||
proxy.activeCallers--;
|
proxy.activeCallers--;
|
||||||
if (proxy.scheduledForClose && proxy.activeCallers < 0) {
|
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);
|
cmProxy.remove(proxy.containerManagerBindAddr);
|
||||||
try {
|
try {
|
||||||
rpc.stopProxy(proxy.getContainerManagementProtocol(), conf);
|
rpc.stopProxy(proxy.getContainerManagementProtocol(), conf);
|
||||||
|
@ -257,7 +261,9 @@ public class ContainerManagementProtocolProxy {
|
||||||
|
|
||||||
final InetSocketAddress cmAddr =
|
final InetSocketAddress cmAddr =
|
||||||
NetUtils.createSocketAddr(containerManagerBindAddr);
|
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
|
// the user in createRemoteUser in this context has to be ContainerID
|
||||||
UserGroupInformation user =
|
UserGroupInformation user =
|
||||||
UserGroupInformation.createRemoteUser(containerId
|
UserGroupInformation.createRemoteUser(containerId
|
||||||
|
|
Loading…
Reference in New Issue