diff --git hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/ZKRMStateStore.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/ZKRMStateStore.java index 9b15bb2..cedeef5 100644 --- hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/ZKRMStateStore.java +++ hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/ZKRMStateStore.java @@ -539,7 +539,7 @@ private void loadApplicationAttemptState(ApplicationState appState, 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 @@ -572,7 +572,7 @@ public synchronized void updateApplicationStateInternal(ApplicationId appId, } else { createWithRetries(nodeUpdatePath, appStateData, zkAcl, 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."); } } @@ -615,7 +615,7 @@ public synchronized void updateApplicationAttemptStateInternal( } else { createWithRetries(nodeUpdatePath, attemptStateData, zkAcl, 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."); } } @@ -664,7 +664,7 @@ protected synchronized void removeRMDelegationTokenState( if (existsWithRetries(nodeRemovePath, true) != null) { opList.add(Op.delete(nodeRemovePath, -1)); } else { - LOG.info("Attempted to delete a non-existing znode " + nodeRemovePath); + LOG.debug("Attempted to delete a non-existing znode " + nodeRemovePath); } doMultiWithRetries(opList); } @@ -681,7 +681,7 @@ protected void updateRMDelegationTokenAndSequenceNumberInternal( // in case znode doesn't exist addStoreOrUpdateOps( 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 { // in case znode exists addStoreOrUpdateOps( @@ -763,7 +763,7 @@ protected synchronized void removeRMDTMasterKeyState( if (existsWithRetries(nodeRemovePath, true) != null) { doMultiWithRetries(Op.delete(nodeRemovePath, -1)); } else { - LOG.info("Attempted to delete a non-existing znode " + nodeRemovePath); + LOG.debug("Attempted to delete a non-existing znode " + nodeRemovePath); } } @@ -816,7 +816,7 @@ public synchronized void processWatchEvent(WatchedEvent event) case Expired: // the connection got terminated because of session timeout // call listener to reconnect - LOG.info("Session expired"); + LOG.info("ZKRMStateStore Session expired"); createConnection(); break; default: