You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by ma...@apache.org on 2020/09/01 22:51:49 UTC
[lucene-solr] 06/08: Delete the ephemeral znode held by the leader
to trigger the watcher on the next replica inline
This is an automated email from the ASF dual-hosted git repository.
markrmiller pushed a commit to branch reference_impl
in repository https://gitbox.apache.org/repos/asf/lucene-solr.git
commit 1cf199c9d50d02a42efbbc2ab089d8133929edba
Author: Timothy Potter <th...@gmail.com>
AuthorDate: Tue Sep 1 16:38:58 2020 -0600
Delete the ephemeral znode held by the leader to trigger the watcher on the next replica inline
---
.../src/java/org/apache/solr/cloud/ShardLeaderElectionContextBase.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/solr/core/src/java/org/apache/solr/cloud/ShardLeaderElectionContextBase.java b/solr/core/src/java/org/apache/solr/cloud/ShardLeaderElectionContextBase.java
index c8138f8..260607a 100644
--- a/solr/core/src/java/org/apache/solr/cloud/ShardLeaderElectionContextBase.java
+++ b/solr/core/src/java/org/apache/solr/cloud/ShardLeaderElectionContextBase.java
@@ -83,7 +83,7 @@ class ShardLeaderElectionContextBase extends ElectionContext {
log.debug("Removing leader registration node on cancel: {} {}", leaderPath, version);
List<Op> ops = new ArrayList<>(2);
ops.add(Op.check(Paths.get(leaderPath).getParent().toString(), version));
- ops.add(Op.check(leaderSeqPath, -1));
+ ops.add(Op.delete(leaderSeqPath, -1));
ops.add(Op.delete(leaderPath, -1));
zkClient.multi(ops);
} catch (KeeperException e) {