HBASE-8583 Create a new IntegrationTestBigLinkedListWithChaosMonkey
git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1486255 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
bf4a3af4a4
commit
c19b7ba9d9
|
@ -116,7 +116,7 @@ public class IntegrationTestingUtility extends HBaseTestingUtility {
|
|||
* cluster or a local cluster.
|
||||
* @see IntegrationTestingUtility#setUseDistributedCluster(Configuration)
|
||||
*/
|
||||
private boolean isDistributedCluster() {
|
||||
public boolean isDistributedCluster() {
|
||||
Configuration conf = getConfiguration();
|
||||
boolean isDistributedCluster = false;
|
||||
isDistributedCluster = Boolean.parseBoolean(System.getProperty(IS_DISTRIBUTED_CLUSTER, "false"));
|
||||
|
|
|
@ -148,9 +148,9 @@ import org.junit.experimental.categories.Category;
|
|||
@Category(IntegrationTests.class)
|
||||
public class IntegrationTestBigLinkedList extends Configured implements Tool {
|
||||
|
||||
private static final String TABLE_NAME_KEY = "IntegrationTestBigLinkedList.table";
|
||||
protected static String TABLE_NAME_KEY = "IntegrationTestBigLinkedList.table";
|
||||
|
||||
private static final String DEFAULT_TABLE_NAME = "IntegrationTestBigLinkedList";
|
||||
protected static String DEFAULT_TABLE_NAME = "IntegrationTestBigLinkedList";
|
||||
|
||||
private static byte[] FAMILY_NAME = Bytes.toBytes("meta");
|
||||
|
||||
|
@ -170,6 +170,8 @@ public class IntegrationTestBigLinkedList extends Configured implements Tool {
|
|||
private static final String GENERATOR_NUM_MAPPERS_KEY
|
||||
= "IntegrationTestBigLinkedList.generator.map.tasks";
|
||||
|
||||
protected int NUM_SLAVES_BASE = 3; // number of slaves for the cluster
|
||||
|
||||
static class CINode {
|
||||
long key;
|
||||
long prev;
|
||||
|
@ -648,7 +650,7 @@ public class IntegrationTestBigLinkedList extends Configured implements Tool {
|
|||
* Executes Generate and Verify in a loop. Data is not cleaned between runs, so each iteration
|
||||
* adds more data.
|
||||
*/
|
||||
private static class Loop extends Configured implements Tool {
|
||||
static class Loop extends Configured implements Tool {
|
||||
|
||||
private static final Log LOG = LogFactory.getLog(Loop.class);
|
||||
|
||||
|
@ -916,12 +918,12 @@ public class IntegrationTestBigLinkedList extends Configured implements Tool {
|
|||
return node;
|
||||
}
|
||||
|
||||
private IntegrationTestingUtility util;
|
||||
protected IntegrationTestingUtility util;
|
||||
|
||||
@Before
|
||||
public void setUp() throws Exception {
|
||||
util = getTestingUtil();
|
||||
util.initializeCluster(3);
|
||||
util.initializeCluster(this.NUM_SLAVES_BASE);
|
||||
this.setConf(util.getConfiguration());
|
||||
}
|
||||
|
||||
|
@ -939,7 +941,7 @@ public class IntegrationTestBigLinkedList extends Configured implements Tool {
|
|||
org.junit.Assert.assertEquals(0, ret);
|
||||
}
|
||||
|
||||
private IntegrationTestingUtility getTestingUtil() {
|
||||
protected IntegrationTestingUtility getTestingUtil() {
|
||||
if (this.util == null) {
|
||||
if (getConf() == null) {
|
||||
this.util = new IntegrationTestingUtility();
|
||||
|
|
|
@ -930,7 +930,7 @@ public class HRegionServer implements ClientProtos.ClientService.BlockingInterfa
|
|||
}
|
||||
|
||||
//fsOk flag may be changed when closing regions throws exception.
|
||||
if (!this.killed && this.fsOk) {
|
||||
if (this.fsOk) {
|
||||
closeWAL(!abortRequested);
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue