You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@solr.apache.org by is...@apache.org on 2022/01/03 08:08:39 UTC
[solr] 18/28: removed unnecessary changes
This is an automated email from the ASF dual-hosted git repository.
ishan pushed a commit to branch jira/SOLR15694
in repository https://gitbox.apache.org/repos/asf/solr.git
commit 525ff87d6cc39362528d7e4bcc0e0876699777f1
Author: Noble Paul <no...@gmail.com>
AuthorDate: Fri Dec 17 16:37:59 2021 +1100
removed unnecessary changes
---
solr/core/src/java/org/apache/solr/cloud/ZkController.java | 6 ++----
1 file changed, 2 insertions(+), 4 deletions(-)
diff --git a/solr/core/src/java/org/apache/solr/cloud/ZkController.java b/solr/core/src/java/org/apache/solr/cloud/ZkController.java
index 33ea43d..a249e4f 100644
--- a/solr/core/src/java/org/apache/solr/cloud/ZkController.java
+++ b/solr/core/src/java/org/apache/solr/cloud/ZkController.java
@@ -685,9 +685,7 @@ public class ZkController implements Closeable {
} finally {
// just in case the OverseerElectionContext managed to start another Overseer
- if(overseer != null) {
- IOUtils.closeQuietly(overseer);
- }
+ IOUtils.closeQuietly(overseer);
ExecutorUtil.shutdownAndAwaitTermination(customThreadPool);
}
@@ -913,7 +911,7 @@ public class ZkController implements Closeable {
registerLiveNodesListener();
// start the overseer first as following code may need it's processing
- if (!zkRunOnly && cc.nodeRoles.isOverseerAllowed()) {
+ if (!zkRunOnly) {
overseerElector = new LeaderElector(zkClient);
this.overseer = new Overseer((HttpShardHandler) cc.getShardHandlerFactory().getShardHandler(), cc.getUpdateShardHandler(),
CommonParams.CORES_HANDLER_PATH, zkStateReader, this, cloudConfig);