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/09/01 22:51:48 UTC

[lucene-solr] 05/08: @682 If we can't write the state update due to version conflict, bail for new Overseer.

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 46a79d1f14a222915040d1668d8644e86ff5130c
Author: markrmiller@gmail.com <ma...@gmail.com>
AuthorDate: Tue Sep 1 17:12:22 2020 -0500

    @682 If we can't write the state update due to version conflict, bail for new Overseer.
---
 .../java/org/apache/solr/cloud/overseer/ZkStateWriter.java    | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/solr/core/src/java/org/apache/solr/cloud/overseer/ZkStateWriter.java b/solr/core/src/java/org/apache/solr/cloud/overseer/ZkStateWriter.java
index 7dc7dec..cf99221 100644
--- a/solr/core/src/java/org/apache/solr/cloud/overseer/ZkStateWriter.java
+++ b/solr/core/src/java/org/apache/solr/cloud/overseer/ZkStateWriter.java
@@ -254,8 +254,8 @@ public class ZkStateWriter {
             log.info(
                 "Tried to update the cluster state using version={} but we where rejected, currently at {}",
                 prevVersion, c == null ? "null" : c.getZNodeVersion(), e);
-            prevState = reader.getClusterState();
-            continue;
+
+            throw e;
           }
           ParWork.propegateInterrupt(e);
           throw new SolrException(SolrException.ErrorCode.SERVER_ERROR,
@@ -339,9 +339,10 @@ public class ZkStateWriter {
               log.warn(
                   "Tried to update the cluster state using version={} but we where rejected, found {}",
                   c.getZNodeVersion(), stat.getVersion(), bve);
-              lastUpdatedTime = -1;
-              failedUpdates.put(name, c);
-              continue;
+              throw bve;
+           //   lastUpdatedTime = -1;
+//              failedUpdates.put(name, c);
+//              continue;
             }
           } else {