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/10/02 19:57:06 UTC
[lucene-solr] 04/04: @934 Tweaking.
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 4d1da410403226e392e13fc96149b620e279f924
Author: markrmiller@gmail.com <ma...@gmail.com>
AuthorDate: Fri Oct 2 14:49:49 2020 -0500
@934 Tweaking.
---
.../apache/solr/cloud/OverseerElectionContext.java | 26 +++++++++++-----------
1 file changed, 13 insertions(+), 13 deletions(-)
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 893c58f..07e678c 100644
--- a/solr/core/src/java/org/apache/solr/cloud/OverseerElectionContext.java
+++ b/solr/core/src/java/org/apache/solr/cloud/OverseerElectionContext.java
@@ -56,19 +56,19 @@ final class OverseerElectionContext extends ShardLeaderElectionContextBase {
// TODO: the idea here is that we could clear the Overseer queue
// if we knew we are the first Overseer in a cluster startup
// needs more testing in real world vs tests
- if (!weAreReplacement) {
- // kills the queues
- ZkDistributedQueue queue = new ZkDistributedQueue(
- overseer.getZkController().getZkStateReader().getZkClient(),
- "/overseer/queue", new Stats(), 0, new ConnectionManager.IsClosed() {
- public boolean isClosed() {
- return overseer.isClosed() || overseer.getZkController()
- .getCoreContainer().isShutDown();
- }
- });
- clearQueue(queue);
- clearQueue(Overseer.getInternalWorkQueue(zkClient, new Stats()));
- }
+// if (!weAreReplacement) {
+// // kills the queues
+// ZkDistributedQueue queue = new ZkDistributedQueue(
+// overseer.getZkController().getZkStateReader().getZkClient(),
+// "/overseer/queue", new Stats(), 0, new ConnectionManager.IsClosed() {
+// public boolean isClosed() {
+// return overseer.isClosed() || overseer.getZkController()
+// .getCoreContainer().isShutDown();
+// }
+// });
+// clearQueue(queue);
+// clearQueue(Overseer.getInternalWorkQueue(zkClient, new Stats()));
+// }
log.info("Running the leader process for Overseer");