YARN-2721. Suppress NodeExist exception thrown by ZKRMStateStore when it retries creating znode. Contributed by Jian He.
This commit is contained in:
parent
c0e034336c
commit
7e3b5e6f5c
@ -717,6 +717,9 @@ Release 2.6.0 - UNRELEASED
|
||||
YARN-2720. Windows: Wildcard classpath variables not expanded against
|
||||
resources contained in archives. (Craig Welch via cnauroth)
|
||||
|
||||
YARN-2721. Suppress NodeExist exception thrown by ZKRMStateStore when it
|
||||
retries creating znode. (Jian He via zjshen)
|
||||
|
||||
Release 2.5.1 - 2014-09-05
|
||||
|
||||
INCOMPATIBLE CHANGES
|
||||
|
@ -1094,6 +1094,10 @@ T runWithRetries() throws Exception {
|
||||
throw new StoreFencedException();
|
||||
}
|
||||
} catch (KeeperException ke) {
|
||||
if (ke.code() == Code.NODEEXISTS) {
|
||||
LOG.info("znode already exists!");
|
||||
return null;
|
||||
}
|
||||
LOG.info("Exception while executing a ZK operation.", ke);
|
||||
if (shouldRetry(ke.code()) && ++retry < numRetries) {
|
||||
LOG.info("Retrying operation on ZK. Retry no. " + retry);
|
||||
|
Loading…
Reference in New Issue
Block a user