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..1212a91 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 @@ -610,8 +610,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 +657,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 +740,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(); @@ -753,12 +759,12 @@ private void addStoreOrUpdateOps(SafeTransaction trx, ByteArrayOutputStream seqOs = new ByteArrayOutputStream(); try (DataOutputStream seqOut = new DataOutputStream(seqOs)) { - if (LOG.isDebugEnabled()) { - LOG.debug((isUpdate ? "Storing " : "Updating ") + "RMDelegationToken_" - + rmDTIdentifier.getSequenceNumber()); - } if (isUpdate) { + if (LOG.isDebugEnabled()) { + LOG.debug("Updating RMDelegationToken_" + + rmDTIdentifier.getSequenceNumber()); + } trx.setData(nodeCreatePath, identifierData.toByteArray(), -1); } else { trx.create(nodeCreatePath, identifierData.toByteArray(), zkAcl, @@ -767,8 +773,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()); }