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/08/12 04:27:51 UTC

[lucene-solr] branch reference_impl_dev updated: @521 Remove silly wait.

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


The following commit(s) were added to refs/heads/reference_impl_dev by this push:
     new 9b43d2e  @521 Remove silly wait.
9b43d2e is described below

commit 9b43d2e3ff651bb1361ba979617b037276aa6d93
Author: markrmiller@gmail.com <ma...@gmail.com>
AuthorDate: Tue Aug 11 23:23:12 2020 -0500

    @521 Remove silly wait.
---
 .../solr/update/processor/DistributedZkUpdateProcessor.java  | 12 ------------
 1 file changed, 12 deletions(-)

diff --git a/solr/core/src/java/org/apache/solr/update/processor/DistributedZkUpdateProcessor.java b/solr/core/src/java/org/apache/solr/update/processor/DistributedZkUpdateProcessor.java
index 79a137c..b0af3f1 100644
--- a/solr/core/src/java/org/apache/solr/update/processor/DistributedZkUpdateProcessor.java
+++ b/solr/core/src/java/org/apache/solr/update/processor/DistributedZkUpdateProcessor.java
@@ -1095,18 +1095,6 @@ public class DistributedZkUpdateProcessor extends DistributedUpdateProcessor {
       }
     }
 
-    int count = 0;
-    while (((isLeader && !localIsLeader) || (isSubShardLeader && !localIsLeader)) && count < 5) {
-      count++;
-      // re-getting localIsLeader since we published to ZK first before setting localIsLeader value
-      localIsLeader = cloudDesc.isLeader();
-      try {
-        Thread.sleep(500);
-      } catch (InterruptedException e) {
-        ParWork.propegateInterrupt(e);
-      }
-    }
-
     if ((isLeader && !localIsLeader) || (isSubShardLeader && !localIsLeader)) {
       log.error("ClusterState says we are the leader, but locally we don't think so");
       throw new SolrException(SolrException.ErrorCode.SERVICE_UNAVAILABLE,