Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

YARN-2061. Revisit logging levels in ZKRMStateStore. (Ray Chiang via kasha) 

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1600498 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Karthik Kambatla 2014-06-04 21:11:09 +00:00
parent 731f417f67
commit d1d6bb70f4
2 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
hadoop-yarn-project/CHANGES.txt
View File

@ -135,6 +135,8 @@ Release 2.5.0 - UNRELEASED
YARN-1913. With Fair Scheduler, cluster can logjam when all resources are YARN-1913. With Fair Scheduler, cluster can logjam when all resources are
consumed by AMs (Wei Yan via Sandy Ryza) consumed by AMs (Wei Yan via Sandy Ryza)
YARN-2061. Revisit logging levels in ZKRMStateStore. (Ray Chiang via kasha)
OPTIMIZATIONS OPTIMIZATIONS
BUG FIXES BUG FIXES

14
hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/ZKRMStateStore.java
View File

@ -546,7 +546,7 @@ private void loadApplicationAttemptState(ApplicationState appState,
appState.attempts.put(attemptState.getAttemptId(), attemptState); appState.attempts.put(attemptState.getAttemptId(), attemptState);
} }
} }
LOG.info("Done Loading applications from ZK state store"); LOG.debug("Done Loading applications from ZK state store");
} }
@Override @Override
@ -579,7 +579,7 @@ public synchronized void updateApplicationStateInternal(ApplicationId appId,
} else { } else {
createWithRetries(nodeUpdatePath, appStateData, zkAcl, createWithRetries(nodeUpdatePath, appStateData, zkAcl,
CreateMode.PERSISTENT); CreateMode.PERSISTENT);
LOG.info(appId + " znode didn't exist. Created a new znode to" LOG.debug(appId + " znode didn't exist. Created a new znode to"
+ " update the application state."); + " update the application state.");
} }
} }
@ -622,7 +622,7 @@ public synchronized void updateApplicationAttemptStateInternal(
} else { } else {
createWithRetries(nodeUpdatePath, attemptStateData, zkAcl, createWithRetries(nodeUpdatePath, attemptStateData, zkAcl,
CreateMode.PERSISTENT); CreateMode.PERSISTENT);
LOG.info(appAttemptId + " znode didn't exist. Created a new znode to" LOG.debug(appAttemptId + " znode didn't exist. Created a new znode to"
+ " update the application attempt state."); + " update the application attempt state.");
} }
} }
@ -671,7 +671,7 @@ protected synchronized void removeRMDelegationTokenState(
if (existsWithRetries(nodeRemovePath, true) != null) { if (existsWithRetries(nodeRemovePath, true) != null) {
opList.add(Op.delete(nodeRemovePath, -1)); opList.add(Op.delete(nodeRemovePath, -1));
} else { } else {
LOG.info("Attempted to delete a non-existing znode " + nodeRemovePath); LOG.debug("Attempted to delete a non-existing znode " + nodeRemovePath);
} }
doMultiWithRetries(opList); doMultiWithRetries(opList);
} }
@ -688,7 +688,7 @@ protected void updateRMDelegationTokenAndSequenceNumberInternal(
// in case znode doesn't exist // in case znode doesn't exist
addStoreOrUpdateOps( addStoreOrUpdateOps(
opList, rmDTIdentifier, renewDate, latestSequenceNumber, false); opList, rmDTIdentifier, renewDate, latestSequenceNumber, false);
LOG.info("Attempted to update a non-existing znode " + nodeRemovePath); LOG.debug("Attempted to update a non-existing znode " + nodeRemovePath);
} else { } else {
// in case znode exists // in case znode exists
addStoreOrUpdateOps( addStoreOrUpdateOps(
@ -770,7 +770,7 @@ protected synchronized void removeRMDTMasterKeyState(
if (existsWithRetries(nodeRemovePath, true) != null) { if (existsWithRetries(nodeRemovePath, true) != null) {
doMultiWithRetries(Op.delete(nodeRemovePath, -1)); doMultiWithRetries(Op.delete(nodeRemovePath, -1));
} else { } else {
LOG.info("Attempted to delete a non-existing znode " + nodeRemovePath); LOG.debug("Attempted to delete a non-existing znode " + nodeRemovePath);
} }
} }
@ -823,7 +823,7 @@ public synchronized void processWatchEvent(WatchedEvent event)
case Expired: case Expired:
// the connection got terminated because of session timeout // the connection got terminated because of session timeout
// call listener to reconnect // call listener to reconnect
LOG.info("Session expired"); LOG.info("ZKRMStateStore Session expired");
createConnection(); createConnection();
break; break;
default: default: