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/07/15 17:00:54 UTC
[lucene-solr] branch reference_impl updated: #176 - Improve
Overseer election version of same thing.
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
The following commit(s) were added to refs/heads/reference_impl by this push:
new 2df3175 #176 - Improve Overseer election version of same thing.
2df3175 is described below
commit 2df3175e88cf01a0e50856cbf7b78fcef101335f
Author: markrmiller@gmail.com <ma...@gmail.com>
AuthorDate: Wed Jul 15 11:52:40 2020 -0500
#176 - Improve Overseer election version of same thing.
---
solr/core/src/java/org/apache/solr/cloud/OverseerElectionContext.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/solr/core/src/java/org/apache/solr/cloud/OverseerElectionContext.java b/solr/core/src/java/org/apache/solr/cloud/OverseerElectionContext.java
index 256cb13..e6979ae 100644
--- a/solr/core/src/java/org/apache/solr/cloud/OverseerElectionContext.java
+++ b/solr/core/src/java/org/apache/solr/cloud/OverseerElectionContext.java
@@ -44,7 +44,8 @@ final class OverseerElectionContext extends ShardLeaderElectionContextBase {
@Override
void runLeaderProcess(ElectionContext context, boolean weAreReplacement, int pauseBeforeStartMs) throws KeeperException,
InterruptedException, IOException {
- if (isClosed) {
+ if (isClosed || zkClient.isClosed()) {
+ log.info("Bailing on becoming leader, we are closed");
return;
}