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 cf6380f..1d911c5 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 @@ -289,7 +289,9 @@ private void logRootNodeAcls(String prefix) throws Exception { } builder.append(getStat.toString()); - LOG.debug(builder.toString()); + if (LOG.isDebugEnabled()) { + LOG.debug(builder.toString()); + } } private void setRootNodeAcls() throws Exception { @@ -575,7 +577,9 @@ private void loadApplicationAttemptState(ApplicationStateData appState, } } - LOG.debug("Done loading applications from ZK state store"); + if (LOG.isDebugEnabled()) { + LOG.debug("Done loading applications from ZK state store"); + } } @Override @@ -610,8 +614,10 @@ protected synchronized void updateApplicationStateInternal( } else { safeCreate(nodeUpdatePath, appStateData, zkAcl, CreateMode.PERSISTENT); - LOG.debug(appId + " znode didn't exist. Created a new znode to" - + " update the application state."); + if (LOG.isDebugEnabled()) { + LOG.debug(appId + " znode didn't exist. Created a new znode to" + + " update the application state."); + } } } @@ -655,8 +661,10 @@ protected synchronized void updateApplicationAttemptStateInternal( } else { safeCreate(nodeUpdatePath, attemptStateData, zkAcl, CreateMode.PERSISTENT); - LOG.debug(appAttemptId + " znode didn't exist. Created a new znode to" - + " update the application attempt state."); + if (LOG.isDebugEnabled()) { + LOG.debug(appAttemptId + " znode didn't exist. Created a new znode to" + + " update the application attempt state."); + } } } @@ -736,7 +744,9 @@ protected synchronized void updateRMDelegationTokenState( } else { // in case znode doesn't exist addStoreOrUpdateOps(trx, rmDTIdentifier, renewDate, false); - LOG.debug("Attempted to update a non-existing znode " + nodeRemovePath); + if (LOG.isDebugEnabled()) { + LOG.debug("Attempted to update a non-existing znode " + nodeRemovePath); + } } trx.commit(); @@ -754,7 +764,7 @@ private void addStoreOrUpdateOps(SafeTransaction trx, try (DataOutputStream seqOut = new DataOutputStream(seqOs)) { if (LOG.isDebugEnabled()) { - LOG.debug((isUpdate ? "Storing " : "Updating ") + "RMDelegationToken_" + LOG.debug((isUpdate ? "Updating " : "Storing ") + "RMDelegationToken_" + rmDTIdentifier.getSequenceNumber()); } @@ -767,8 +777,7 @@ private void addStoreOrUpdateOps(SafeTransaction trx, seqOut.writeInt(rmDTIdentifier.getSequenceNumber()); if (LOG.isDebugEnabled()) { - LOG.debug((isUpdate ? "Storing " : "Updating ") - + dtSequenceNumberPath + ". SequenceNumber: " + LOG.debug("Storing " + dtSequenceNumberPath + ". SequenceNumber: " + rmDTIdentifier.getSequenceNumber()); }