You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by ro...@apache.org on 2016/09/22 12:22:03 UTC

[2/2] lucene-solr:branch_6x: SOLR-9305, SOLR-9390: *really* dont' use directToLeaders

SOLR-9305, SOLR-9390: *really* dont' use directToLeaders


Project: http://git-wip-us.apache.org/repos/asf/lucene-solr/repo
Commit: http://git-wip-us.apache.org/repos/asf/lucene-solr/commit/00035c85
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/00035c85
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/00035c85

Branch: refs/heads/branch_6x
Commit: 00035c85114bc09c24c9cc9c0364030cf621d374
Parents: 09a39e1
Author: Alan Woodward <ro...@apache.org>
Authored: Thu Sep 22 13:21:23 2016 +0100
Committer: Alan Woodward <ro...@apache.org>
Committed: Thu Sep 22 13:21:47 2016 +0100

----------------------------------------------------------------------
 solr/core/src/test/org/apache/solr/cloud/HttpPartitionTest.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/00035c85/solr/core/src/test/org/apache/solr/cloud/HttpPartitionTest.java
----------------------------------------------------------------------
diff --git a/solr/core/src/test/org/apache/solr/cloud/HttpPartitionTest.java b/solr/core/src/test/org/apache/solr/cloud/HttpPartitionTest.java
index 2038111..01a6c8e 100644
--- a/solr/core/src/test/org/apache/solr/cloud/HttpPartitionTest.java
+++ b/solr/core/src/test/org/apache/solr/cloud/HttpPartitionTest.java
@@ -87,7 +87,10 @@ public class HttpPartitionTest extends AbstractFullDistribZkTestBase {
    */
   @Override
   protected CloudSolrClient createCloudClient(String defaultCollection) {
-    CloudSolrClient client = getCloudSolrClient(zkServer.getZkAddress(), false);
+    CloudSolrClient client = new CloudSolrClient.Builder()
+        .withZkHost(zkServer.getZkAddress())
+        .sendDirectUpdatesToAnyShardReplica()
+        .build();
     client.setParallelUpdates(random().nextBoolean());
     if (defaultCollection != null) client.setDefaultCollection(defaultCollection);
     client.getLbClient().setConnectionTimeout(30000);