|
@@ -998,13 +998,13 @@ public class ZKRMStateStore extends RMStateStore {
|
|
|
throw new StoreFencedException();
|
|
|
}
|
|
|
} catch (KeeperException ke) {
|
|
|
+ LOG.info("Exception while executing a ZK operation.", ke);
|
|
|
if (shouldRetry(ke.code()) && ++retry < numRetries) {
|
|
|
- LOG.info("Waiting for zookeeper to be connected, retry no. + "
|
|
|
- + retry);
|
|
|
+ LOG.info("Retrying operation on ZK. Retry no. " + retry);
|
|
|
Thread.sleep(zkRetryInterval);
|
|
|
continue;
|
|
|
}
|
|
|
- LOG.debug("Error while doing ZK operation.", ke);
|
|
|
+ LOG.info("Maxed out ZK retries. Giving up!");
|
|
|
throw ke;
|
|
|
}
|
|
|
}
|