svn commit: r1653328 - /lucene/dev/trunk/solr/core/src/test/org/apache/solr/handler/TestBlobHandler.java

[no...@apache.org]

Author: noble
Date: Tue Jan 20 18:25:01 2015
New Revision: 1653328

URL: http://svn.apache.org/r1653328
Log:
 SOLR-6801 test always writes to leader so that replication lag does not impact next insertion

Modified:
    lucene/dev/trunk/solr/core/src/test/org/apache/solr/handler/TestBlobHandler.java

Modified: lucene/dev/trunk/solr/core/src/test/org/apache/solr/handler/TestBlobHandler.java
URL: http://svn.apache.org/viewvc/lucene/dev/trunk/solr/core/src/test/org/apache/solr/handler/TestBlobHandler.java?rev=1653328&r1=1653327&r2=1653328&view=diff
==============================================================================
--- lucene/dev/trunk/solr/core/src/test/org/apache/solr/handler/TestBlobHandler.java (original)
+++ lucene/dev/trunk/solr/core/src/test/org/apache/solr/handler/TestBlobHandler.java Tue Jan 20 18:25:01 2015
@@ -177,8 +177,9 @@ public class TestBlobHandler extends Abs
     HttpPost httpPost = null;
     HttpEntity entity;
     String response = null;
+    Replica leader = cloudClient.getZkStateReader().getClusterState().getCollection(".system").getActiveSlices().iterator().next().getLeader();
     try {
-      httpPost = new HttpPost(baseUrl+"/.system/blob/test");
+      httpPost = new HttpPost(leader.getStr(ZkStateReader.BASE_URL_PROP) +"/.system/blob/test");
       httpPost.setHeader("Content-Type","application/octet-stream");
       httpPost.setEntity(new ByteArrayEntity(bytarr.array(), bytarr.arrayOffset(), bytarr.limit()));
       entity = cloudClient.getLbClient().getHttpClient().execute(httpPost).getEntity();