Details
-
Improvement
-
Status: Closed
-
Trivial
-
Resolution: Fixed
-
7.7
-
None
-
None
Description
ElectionContext.java
@Override void runLeaderProcess(boolean weAreReplacement, int pauseBeforeStartMs) throws KeeperException, InterruptedException, IOException { String parent = new Path(leaderPath).getParent().toString(); try { RetryUtil.retryOnThrowable(NodeExistsException.class, 60000, 5000, () -> { synchronized (lock) { ........ List<Op> ops = new ArrayList<>(2); //HERE SHOULD BE 3 OR MORE ops.add(Op.check(leaderSeqPath, -1)); ops.add(Op.create(leaderPath, Utils.toJSON(leaderProps), zkClient.getZkACLProvider().getACLsToAdd(leaderPath), CreateMode.EPHEMERAL)); ops.add(Op.setData(parent, null, -1)); List<OpResult> results; results = zkClient.multi(ops, true); ....... }
Attachments
Attachments
Issue Links
- is related to
-
SOLR-15446 fix some off-by-one initialCapacity choices when calling ZooKeeper.multi
- Closed
- links to