Add log.warn when a replica become leader after timeout

This commit is contained in:
Cao Manh Dat 2018-10-24 08:56:01 +07:00
parent 3e89b7a771
commit e083b1501e
1 changed files with 3 additions and 0 deletions

View File

@ -522,6 +522,9 @@ final class ShardLeaderElectionContext extends ShardLeaderElectionContextBase {
long timeoutAt = System.nanoTime() + TimeUnit.NANOSECONDS.convert(timeout, TimeUnit.MILLISECONDS); long timeoutAt = System.nanoTime() + TimeUnit.NANOSECONDS.convert(timeout, TimeUnit.MILLISECONDS);
while (!isClosed && !cc.isShutDown()) { while (!isClosed && !cc.isShutDown()) {
if (System.nanoTime() > timeoutAt) { if (System.nanoTime() > timeoutAt) {
log.warn("After waiting for {}ms, no other potential leader was found, {} try to become leader anyway (" +
"core_term:{}, highest_term:{})",
timeout, coreNodeName, zkShardTerms.getTerm(coreNodeName), zkShardTerms.getHighestTerm());
return true; return true;
} }
if (replicasWithHigherTermParticipated(zkShardTerms, coreNodeName)) { if (replicasWithHigherTermParticipated(zkShardTerms, coreNodeName)) {