mirror of https://github.com/apache/lucene.git
tests: fix for random map order
git-svn-id: https://svn.apache.org/repos/asf/lucene/dev/trunk@1544980 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
e61acfdb0d
commit
633ea330fe
|
@ -25,7 +25,6 @@ import java.util.concurrent.ThreadPoolExecutor;
|
||||||
import java.util.concurrent.TimeUnit;
|
import java.util.concurrent.TimeUnit;
|
||||||
|
|
||||||
import org.apache.lucene.util.LuceneTestCase.Slow;
|
import org.apache.lucene.util.LuceneTestCase.Slow;
|
||||||
import org.apache.lucene.util.Constants;
|
|
||||||
import org.apache.solr.client.solrj.SolrQuery;
|
import org.apache.solr.client.solrj.SolrQuery;
|
||||||
import org.apache.solr.client.solrj.SolrServer;
|
import org.apache.solr.client.solrj.SolrServer;
|
||||||
import org.apache.solr.client.solrj.SolrServerException;
|
import org.apache.solr.client.solrj.SolrServerException;
|
||||||
|
@ -33,7 +32,6 @@ import org.apache.solr.client.solrj.impl.HttpSolrServer;
|
||||||
import org.apache.solr.client.solrj.request.CoreAdminRequest.Create;
|
import org.apache.solr.client.solrj.request.CoreAdminRequest.Create;
|
||||||
import org.apache.solr.client.solrj.request.CoreAdminRequest.Unload;
|
import org.apache.solr.client.solrj.request.CoreAdminRequest.Unload;
|
||||||
import org.apache.solr.common.SolrInputDocument;
|
import org.apache.solr.common.SolrInputDocument;
|
||||||
import org.apache.solr.common.cloud.Slice;
|
|
||||||
import org.apache.solr.common.cloud.ZkCoreNodeProps;
|
import org.apache.solr.common.cloud.ZkCoreNodeProps;
|
||||||
import org.apache.solr.common.cloud.ZkStateReader;
|
import org.apache.solr.common.cloud.ZkStateReader;
|
||||||
import org.apache.solr.common.params.ModifiableSolrParams;
|
import org.apache.solr.common.params.ModifiableSolrParams;
|
||||||
|
@ -51,7 +49,7 @@ public class UnloadDistributedZkTest extends BasicDistributedZkTest {
|
||||||
|
|
||||||
@BeforeClass
|
@BeforeClass
|
||||||
public static void beforeThisClass3() throws Exception {
|
public static void beforeThisClass3() throws Exception {
|
||||||
assumeFalse("FIXME: This test fails under Java 8 all the time, see SOLR-4711", Constants.JRE_IS_MINIMUM_JAVA8);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Before
|
@Before
|
||||||
|
@ -120,21 +118,17 @@ public class UnloadDistributedZkTest extends BasicDistributedZkTest {
|
||||||
server.request(unloadCmd);
|
server.request(unloadCmd);
|
||||||
|
|
||||||
// there should be only one shard
|
// there should be only one shard
|
||||||
Slice shard2 = getCommonCloudSolrServer().getZkStateReader().getClusterState().getSlice(collection, "shard2");
|
int slices = getCommonCloudSolrServer().getZkStateReader().getClusterState().getSlices(collection).size();
|
||||||
long timeoutAt = System.currentTimeMillis() + 45000;
|
long timeoutAt = System.currentTimeMillis() + 45000;
|
||||||
while (shard2 != null) {
|
while (slices != 1) {
|
||||||
if (System.currentTimeMillis() > timeoutAt) {
|
if (System.currentTimeMillis() > timeoutAt) {
|
||||||
printLayout();
|
printLayout();
|
||||||
fail("Still found shard2 in collection " + collection);
|
fail("Expected to find only one slice in " + collection);
|
||||||
}
|
}
|
||||||
|
|
||||||
Thread.sleep(1000);
|
Thread.sleep(1000);
|
||||||
shard2 = getCommonCloudSolrServer().getZkStateReader().getClusterState().getSlice(collection, "shard2");
|
slices = getCommonCloudSolrServer().getZkStateReader().getClusterState().getSlices(collection).size();
|
||||||
}
|
}
|
||||||
|
|
||||||
Slice shard1 = getCommonCloudSolrServer().getZkStateReader().getClusterState().getSlice(collection, "shard1");
|
|
||||||
assertNotNull(shard1);
|
|
||||||
assertTrue(getCommonCloudSolrServer().getZkStateReader().getClusterState().getCollections().contains(collection));
|
|
||||||
|
|
||||||
// now unload one of the other
|
// now unload one of the other
|
||||||
unloadCmd = new Unload(false);
|
unloadCmd = new Unload(false);
|
||||||
|
|
Loading…
Reference in New Issue