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/11/10 22:10:33 UTC
[lucene-solr] 05/07: @1147 Don't use version from clusterstate
object.
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 376d23659eebfd636d8e1614e9b6162e77bbb0d6
Author: markrmiller@gmail.com <ma...@gmail.com>
AuthorDate: Tue Nov 10 15:40:35 2020 -0600
@1147 Don't use version from clusterstate object.
---
solr/core/src/java/org/apache/solr/cloud/overseer/ZkStateWriter.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
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 c90db99..971e505 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
@@ -330,10 +330,13 @@ public class ZkStateWriter {
if (log.isDebugEnabled()) log.debug("Write state.json prevVersion={} bytes={} col={}", collection.getZNodeVersion(), data.length, collection);
try {
- int version = collection.getZNodeVersion();
+
Integer v = trackVersions.get(collection.getName());
+ Integer version;
if (v != null) {
version = v;
+ } else {
+ version = reader.getZkClient().exists(path, null).getVersion();
}
lastVersion.set(version);
reader.getZkClient().setData(path, data, version, true);