Skip to content

Commit 2d51e9e

Browse files
committed
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
1 parent 3fbb7a8 commit 2d51e9e

File tree

2 files changed

+9
-7
lines changed
  • hadoop-yarn-project
    • hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/recovery

2 files changed

+9
-7
lines changed

hadoop-yarn-project/CHANGES.txt

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -135,6 +135,8 @@ Release 2.5.0 - UNRELEASED
135135
YARN-1913. With Fair Scheduler, cluster can logjam when all resources are
136136
consumed by AMs (Wei Yan via Sandy Ryza)
137137

138+
YARN-2061. Revisit logging levels in ZKRMStateStore. (Ray Chiang via kasha)
139+
138140
OPTIMIZATIONS
139141

140142
BUG FIXES

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

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -546,7 +546,7 @@ private void loadApplicationAttemptState(ApplicationState appState,
546546
appState.attempts.put(attemptState.getAttemptId(), attemptState);
547547
}
548548
}
549-
LOG.info("Done Loading applications from ZK state store");
549+
LOG.debug("Done Loading applications from ZK state store");
550550
}
551551

552552
@Override
@@ -579,7 +579,7 @@ public synchronized void updateApplicationStateInternal(ApplicationId appId,
579579
} else {
580580
createWithRetries(nodeUpdatePath, appStateData, zkAcl,
581581
CreateMode.PERSISTENT);
582-
LOG.info(appId + " znode didn't exist. Created a new znode to"
582+
LOG.debug(appId + " znode didn't exist. Created a new znode to"
583583
+ " update the application state.");
584584
}
585585
}
@@ -622,7 +622,7 @@ public synchronized void updateApplicationAttemptStateInternal(
622622
} else {
623623
createWithRetries(nodeUpdatePath, attemptStateData, zkAcl,
624624
CreateMode.PERSISTENT);
625-
LOG.info(appAttemptId + " znode didn't exist. Created a new znode to"
625+
LOG.debug(appAttemptId + " znode didn't exist. Created a new znode to"
626626
+ " update the application attempt state.");
627627
}
628628
}
@@ -671,7 +671,7 @@ protected synchronized void removeRMDelegationTokenState(
671671
if (existsWithRetries(nodeRemovePath, true) != null) {
672672
opList.add(Op.delete(nodeRemovePath, -1));
673673
} else {
674-
LOG.info("Attempted to delete a non-existing znode " + nodeRemovePath);
674+
LOG.debug("Attempted to delete a non-existing znode " + nodeRemovePath);
675675
}
676676
doMultiWithRetries(opList);
677677
}
@@ -688,7 +688,7 @@ protected void updateRMDelegationTokenAndSequenceNumberInternal(
688688
// in case znode doesn't exist
689689
addStoreOrUpdateOps(
690690
opList, rmDTIdentifier, renewDate, latestSequenceNumber, false);
691-
LOG.info("Attempted to update a non-existing znode " + nodeRemovePath);
691+
LOG.debug("Attempted to update a non-existing znode " + nodeRemovePath);
692692
} else {
693693
// in case znode exists
694694
addStoreOrUpdateOps(
@@ -770,7 +770,7 @@ protected synchronized void removeRMDTMasterKeyState(
770770
if (existsWithRetries(nodeRemovePath, true) != null) {
771771
doMultiWithRetries(Op.delete(nodeRemovePath, -1));
772772
} else {
773-
LOG.info("Attempted to delete a non-existing znode " + nodeRemovePath);
773+
LOG.debug("Attempted to delete a non-existing znode " + nodeRemovePath);
774774
}
775775
}
776776

@@ -823,7 +823,7 @@ public synchronized void processWatchEvent(WatchedEvent event)
823823
case Expired:
824824
// the connection got terminated because of session timeout
825825
// call listener to reconnect
826-
LOG.info("Session expired");
826+
LOG.info("ZKRMStateStore Session expired");
827827
createConnection();
828828
break;
829829
default:

0 commit comments

Comments
 (0)