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/25 22:15:16 UTC
[lucene-solr] 03/16: @313 Fix solrzkclient start call in
zkstatereader.
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 0d0e5cb8d15cee7a9794dd985ac0b70e3e450d3d
Author: markrmiller@gmail.com <ma...@gmail.com>
AuthorDate: Wed Jul 22 22:07:34 2020 -0500
@313 Fix solrzkclient start call in zkstatereader.
---
.../solrj/src/java/org/apache/solr/common/cloud/ZkStateReader.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git a/solr/solrj/src/java/org/apache/solr/common/cloud/ZkStateReader.java b/solr/solrj/src/java/org/apache/solr/common/cloud/ZkStateReader.java
index 5b4b3a0..58cabb3 100644
--- a/solr/solrj/src/java/org/apache/solr/common/cloud/ZkStateReader.java
+++ b/solr/solrj/src/java/org/apache/solr/common/cloud/ZkStateReader.java
@@ -359,7 +359,7 @@ public class ZkStateReader implements SolrCloseable {
public void command() {
ZkStateReader.this.createClusterStateWatchersAndUpdate();
}
- }).start();
+ });
this.configManager = new ZkConfigManager(zkClient);
this.closeClient = true;
@@ -411,8 +411,9 @@ public class ZkStateReader implements SolrCloseable {
@SuppressWarnings({"unchecked"})
public synchronized void createClusterStateWatchersAndUpdate() {
-
- zkClient.start();
+ if (closeClient) {
+ zkClient.start();
+ }
log.info("createClusterStateWatchersAndUpdate");
CountDownLatch latch = new CountDownLatch(1);