You are viewing a plain text version of this content. The canonical link for it is here.
Posted to solr-commits@lucene.apache.org by yo...@apache.org on 2010/02/09 21:47:43 UTC

svn commit: r908211 - /lucene/solr/branches/cloud/src/test/org/apache/solr/cloud/BasicDistributedZkTest.java

Author: yonik
Date: Tue Feb  9 20:47:41 2010
New Revision: 908211

URL: http://svn.apache.org/viewvc?rev=908211&view=rev
Log:
solrj distrib test code only fails if you have another server running at 8983

Modified:
    lucene/solr/branches/cloud/src/test/org/apache/solr/cloud/BasicDistributedZkTest.java

Modified: lucene/solr/branches/cloud/src/test/org/apache/solr/cloud/BasicDistributedZkTest.java
URL: http://svn.apache.org/viewvc/lucene/solr/branches/cloud/src/test/org/apache/solr/cloud/BasicDistributedZkTest.java?rev=908211&r1=908210&r2=908211&view=diff
==============================================================================
--- lucene/solr/branches/cloud/src/test/org/apache/solr/cloud/BasicDistributedZkTest.java (original)
+++ lucene/solr/branches/cloud/src/test/org/apache/solr/cloud/BasicDistributedZkTest.java Tue Feb  9 20:47:41 2010
@@ -80,6 +80,8 @@
     params.set("distrib","true");
   }
 
+  // TODO: there is an incorrect localhost:8983 shard registered
+
   protected void createServers(int numShards) throws Exception {
     controlJetty = createJetty(testDir, "control", "control_shardId");
     controlClient = createNewSolrServer(controlJetty.getLocalPort());
@@ -269,7 +271,7 @@
 
   @Override
   protected QueryResponse queryServer(ModifiableSolrParams params) throws SolrServerException {
-    if (true || r.nextBoolean())
+    if (r.nextBoolean())
       return super.queryServer(params);
 
     // use the distributed solrj client
@@ -285,6 +287,9 @@
       }
     }
 
+    if (r.nextBoolean())
+      params.set("collection","collection1");
+
     QueryResponse rsp = solrj.query(params);
     return rsp;
   }