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,