This is an automated email from the ASF dual-hosted git repository.

hossman pushed a commit to branch jira/SOLR-6312
in repository https://gitbox.apache.org/repos/asf/solr.git

commit 52fe0227203cce92574bdb3163602854eefdd639
Author: Chris Hostetter <[email protected]>
AuthorDate: Mon Dec 19 18:04:52 2022 -0700

    Fix tests that expect updates routed to leaders to explicitly configure 
sendUpdatesOnlyToShardLeaders() on their randomized client Builders
---
 .../test/org/apache/solr/client/solrj/impl/CloudHttp2SolrClientTest.java | 1 +
 .../src/test/org/apache/solr/client/solrj/impl/CloudSolrClientTest.java  | 1 +
 2 files changed, 2 insertions(+)

diff --git 
a/solr/solrj/src/test/org/apache/solr/client/solrj/impl/CloudHttp2SolrClientTest.java
 
b/solr/solrj/src/test/org/apache/solr/client/solrj/impl/CloudHttp2SolrClientTest.java
index f245c3bef04..dc844ce627f 100644
--- 
a/solr/solrj/src/test/org/apache/solr/client/solrj/impl/CloudHttp2SolrClientTest.java
+++ 
b/solr/solrj/src/test/org/apache/solr/client/solrj/impl/CloudHttp2SolrClientTest.java
@@ -304,6 +304,7 @@ public class CloudHttp2SolrClientTest extends 
SolrCloudTestCase {
     try (CloudSolrClient threadedClient =
         new CloudSolrClientBuilder(
                 
Collections.singletonList(cluster.getZkServer().getZkAddress()), 
Optional.empty())
+            .sendUpdatesOnlyToShardLeaders()
             .withParallelUpdates(true)
             .build()) {
       threadedClient.setDefaultCollection("routing_collection");
diff --git 
a/solr/solrj/src/test/org/apache/solr/client/solrj/impl/CloudSolrClientTest.java
 
b/solr/solrj/src/test/org/apache/solr/client/solrj/impl/CloudSolrClientTest.java
index 6bd122f3402..101b4787a05 100644
--- 
a/solr/solrj/src/test/org/apache/solr/client/solrj/impl/CloudSolrClientTest.java
+++ 
b/solr/solrj/src/test/org/apache/solr/client/solrj/impl/CloudSolrClientTest.java
@@ -305,6 +305,7 @@ public class CloudSolrClientTest extends SolrCloudTestCase {
     try (CloudSolrClient threadedClient =
         new CloudSolrClientBuilder(
                 
Collections.singletonList(cluster.getZkServer().getZkAddress()), 
Optional.empty())
+            .sendUpdatesOnlyToShardLeaders()
             .withParallelUpdates(true)
             .build()) {
       threadedClient.setDefaultCollection("routing_collection");

Reply via email to