Apache
/
lucene
mirror of https://github.com/apache/lucene.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

SOLR-6157: Added some logging and re-opened the socket proxy to try to figure out why this test is hanging; reenabling temporarily to see if these changes help diagnose the cause of the hang. 

git-svn-id: https://svn.apache.org/repos/asf/lucene/dev/trunk@1602924 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Timothy Potter 2014-06-16 16:44:15 +00:00
parent a54f8a2e4e
commit 46daa9178a
1 changed files with 14 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
solr/core/src/test/org/apache/solr/cloud/ReplicationFactorTest.java
View File

@ -49,10 +49,10 @@ import org.slf4j.LoggerFactory;
/** /**
* Tests a client application's ability to get replication factor * Tests a client application's ability to get replication factor
* information back from the cluster after an add or update. * information back from the cluster after an add or update.
* @AwaitsFix(bugUrl = "https://issues.apache.org/jira/browse/SOLR-6157")
*/ */
@Slow @Slow
@SuppressSSL(bugUrl = "https://issues.apache.org/jira/browse/SOLR-5776") @SuppressSSL(bugUrl = "https://issues.apache.org/jira/browse/SOLR-5776")
@AwaitsFix(bugUrl = "https://issues.apache.org/jira/browse/SOLR-6157")
public class ReplicationFactorTest extends AbstractFullDistribZkTestBase { public class ReplicationFactorTest extends AbstractFullDistribZkTestBase {
private static final transient Logger log = private static final transient Logger log =
@ -132,20 +132,25 @@ public class ReplicationFactorTest extends AbstractFullDistribZkTestBase {
@Override @Override
public void doTest() throws Exception { public void doTest() throws Exception {
log.info("replication factor test running");
waitForThingsToLevelOut(30000); waitForThingsToLevelOut(30000);
// test a 1x3 collection // test a 1x3 collection
log.info("Testing replication factor handling for repfacttest_c8n_1x3");
testRf3(); testRf3();
// test handling when not using direct updates // test handling when not using direct updates
log.info("Now testing replication factor handling for repfacttest_c8n_2x2");
testRf2NotUsingDirectUpdates(); testRf2NotUsingDirectUpdates();
log.info("replication factor testing complete");
} }
protected void testRf2NotUsingDirectUpdates() throws Exception { protected void testRf2NotUsingDirectUpdates() throws Exception {
int numShards = 2; int numShards = 2;
int replicationFactor = 2; int replicationFactor = 2;
int maxShardsPerNode = 1; int maxShardsPerNode = 1;
String testCollectionName = "c8n_2x2"; String testCollectionName = "repfacttest_c8n_2x2";
String shardId = "shard1"; String shardId = "shard1";
int minRf = 2; int minRf = 2;
@ -185,6 +190,11 @@ public class ReplicationFactorTest extends AbstractFullDistribZkTestBase {
// shard1 will have rf=2 but shard2 will only have rf=1 // shard1 will have rf=2 but shard2 will only have rf=1
sendNonDirectUpdateRequestReplica(leader, up, 1, testCollectionName); sendNonDirectUpdateRequestReplica(leader, up, 1, testCollectionName);
sendNonDirectUpdateRequestReplica(replicas.get(0), up, 1, testCollectionName); sendNonDirectUpdateRequestReplica(replicas.get(0), up, 1, testCollectionName);
// heal the partition
getProxyForReplica(shard2Replicas.get(0)).reopen();
Thread.sleep(2000);
} }
@SuppressWarnings("rawtypes") @SuppressWarnings("rawtypes")
@ -210,7 +220,7 @@ public class ReplicationFactorTest extends AbstractFullDistribZkTestBase {
int numShards = 1; int numShards = 1;
int replicationFactor = 3; int replicationFactor = 3;
int maxShardsPerNode = 1; int maxShardsPerNode = 1;
String testCollectionName = "c8n_1x3"; String testCollectionName = "repfacttest_c8n_1x3";
String shardId = "shard1"; String shardId = "shard1";
int minRf = 2; int minRf = 2;