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/11/11 01:33:38 UTC

[lucene-solr] 01/02: @1155 debug logging

This is an automated email from the ASF dual-hosted git repository.

markrmiller pushed a commit to branch reference_impl_dev
in repository https://gitbox.apache.org/repos/asf/lucene-solr.git

commit 3c700b49cb35a0ec553ef29e8df921f63aeb55c1
Author: markrmiller@gmail.com <ma...@gmail.com>
AuthorDate: Tue Nov 10 18:59:12 2020 -0600

    @1155 debug logging
---
 solr/core/src/java/org/apache/solr/cloud/LeaderElector.java | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git a/solr/core/src/java/org/apache/solr/cloud/LeaderElector.java b/solr/core/src/java/org/apache/solr/cloud/LeaderElector.java
index 809ea03..35b3b25 100644
--- a/solr/core/src/java/org/apache/solr/cloud/LeaderElector.java
+++ b/solr/core/src/java/org/apache/solr/cloud/LeaderElector.java
@@ -166,7 +166,7 @@ public class LeaderElector implements Closeable {
       }
 
     } else {
-      log.info("I am not the leader - watch the node below me {}", context.getClass().getSimpleName());
+      log.info("I am not the leader (leaderSeqNodeName={}) - watch the node below me {} seqs={}", leaderSeqNodeName, context.getClass().getSimpleName(), seqs);
       String toWatch = seqs.get(0);
       for (String node : seqs) {
         if (leaderSeqNodeName.equals(node)) {
@@ -383,6 +383,14 @@ public class LeaderElector implements Closeable {
 
   @Override
   public void close() throws IOException {
+    if (context != null) {
+      try {
+        context.cancelElection();
+      } catch (Exception e) {
+        log.warn("Exception canceling election", e);
+      }
+      context.close();
+    }
     IOUtils.closeQuietly(watcher);
     this.isClosed = true;
   }