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/14 16:54:43 UTC
[lucene-solr] branch reference_impl_dev updated: @1198 Hardening.
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 8fd7ab5 @1198 Hardening.
8fd7ab5 is described below
commit 8fd7ab5441541f2ed9de4c4474517dfe5826e3c8
Author: markrmiller@gmail.com <ma...@gmail.com>
AuthorDate: Sat Nov 14 10:54:18 2020 -0600
@1198 Hardening.
---
.../src/java/org/apache/solr/handler/component/CloudReplicaSource.java | 2 +-
.../src/test/org/apache/solr/cloud/TestDownShardTolerantSearch.java | 2 ++
2 files changed, 3 insertions(+), 1 deletion(-)
diff --git a/solr/core/src/java/org/apache/solr/handler/component/CloudReplicaSource.java b/solr/core/src/java/org/apache/solr/handler/component/CloudReplicaSource.java
index badeddc..3cffd11 100644
--- a/solr/core/src/java/org/apache/solr/handler/component/CloudReplicaSource.java
+++ b/solr/core/src/java/org/apache/solr/handler/component/CloudReplicaSource.java
@@ -118,7 +118,7 @@ class CloudReplicaSource implements ReplicaSource {
this.slices = new String[sliceOrUrls.size()];
this.replicas = new List[sliceOrUrls.size()];
this.builder = builder;
-
+
clusterState = builder.zkStateReader.getClusterState();
this.zkStateReader = builder.zkStateReader;
this.collection = clusterState.getCollection(builder.collection);
diff --git a/solr/core/src/test/org/apache/solr/cloud/TestDownShardTolerantSearch.java b/solr/core/src/test/org/apache/solr/cloud/TestDownShardTolerantSearch.java
index cbd4cbd..6e5781d 100644
--- a/solr/core/src/test/org/apache/solr/cloud/TestDownShardTolerantSearch.java
+++ b/solr/core/src/test/org/apache/solr/cloud/TestDownShardTolerantSearch.java
@@ -67,6 +67,8 @@ public class TestDownShardTolerantSearch extends SolrCloudTestCase {
JettySolrRunner stoppedServer = cluster.stopJettySolrRunner(0);
+ Thread.sleep(100);
+
try {
response = cluster.getSolrClient().query("tolerant", new SolrQuery("*:*").setRows(1).setParam(ShardParams.SHARDS_TOLERANT, true));
} catch (BaseHttpSolrClient.RemoteExecutionException e) {