mirror of https://github.com/apache/lucene.git
Tweak leadership election trace to aid debugging
git-svn-id: https://svn.apache.org/repos/asf/lucene/dev/trunk@1685446 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
164972785c
commit
0b0189f77c
|
@ -181,6 +181,7 @@ public class LeaderElector {
|
||||||
String watchedNode = holdElectionPath + "/" + seqs.get(toWatch);
|
String watchedNode = holdElectionPath + "/" + seqs.get(toWatch);
|
||||||
|
|
||||||
zkClient.getData(watchedNode, watcher = new ElectionWatcher(context.leaderSeqPath , watchedNode,seq, context) , null, true);
|
zkClient.getData(watchedNode, watcher = new ElectionWatcher(context.leaderSeqPath , watchedNode,seq, context) , null, true);
|
||||||
|
log.info("Watching path {} to know if I could be the leader", watchedNode);
|
||||||
} catch (KeeperException.SessionExpiredException e) {
|
} catch (KeeperException.SessionExpiredException e) {
|
||||||
throw e;
|
throw e;
|
||||||
} catch (KeeperException e) {
|
} catch (KeeperException e) {
|
||||||
|
@ -278,7 +279,7 @@ public class LeaderElector {
|
||||||
while (cont) {
|
while (cont) {
|
||||||
try {
|
try {
|
||||||
if(joinAtHead){
|
if(joinAtHead){
|
||||||
log.info("node {} Trying to join election at the head ", id);
|
log.info("Node {} trying to join election at the head", id);
|
||||||
List<String> nodes = OverseerCollectionProcessor.getSortedElectionNodes(zkClient, shardsElectZkPath);
|
List<String> nodes = OverseerCollectionProcessor.getSortedElectionNodes(zkClient, shardsElectZkPath);
|
||||||
if(nodes.size() <2){
|
if(nodes.size() <2){
|
||||||
leaderSeqPath = zkClient.create(shardsElectZkPath + "/" + id + "-n_", null,
|
leaderSeqPath = zkClient.create(shardsElectZkPath + "/" + id + "-n_", null,
|
||||||
|
@ -293,14 +294,13 @@ public class LeaderElector {
|
||||||
}
|
}
|
||||||
leaderSeqPath = shardsElectZkPath + "/" + id + "-n_"+ m.group(1);
|
leaderSeqPath = shardsElectZkPath + "/" + id + "-n_"+ m.group(1);
|
||||||
zkClient.create(leaderSeqPath, null, CreateMode.EPHEMERAL, false);
|
zkClient.create(leaderSeqPath, null, CreateMode.EPHEMERAL, false);
|
||||||
log.info("Joined at the head {}", leaderSeqPath );
|
|
||||||
|
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
leaderSeqPath = zkClient.create(shardsElectZkPath + "/" + id + "-n_", null,
|
leaderSeqPath = zkClient.create(shardsElectZkPath + "/" + id + "-n_", null,
|
||||||
CreateMode.EPHEMERAL_SEQUENTIAL, false);
|
CreateMode.EPHEMERAL_SEQUENTIAL, false);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
log.info("Joined leadership election with path: {}", leaderSeqPath);
|
||||||
context.leaderSeqPath = leaderSeqPath;
|
context.leaderSeqPath = leaderSeqPath;
|
||||||
cont = false;
|
cont = false;
|
||||||
} catch (ConnectionLossException e) {
|
} catch (ConnectionLossException e) {
|
||||||
|
|
Loading…
Reference in New Issue