public class IntegrationTestDDLMasterFailover extends IntegrationTestBase
This test should be run by the hbase user since it invokes hbck at the end
Usage: hbase org.apache.hadoop.hbase.IntegrationTestDDLMasterFailover -Dhbase.IntegrationTestDDLMasterFailover.runtime=1200000 -Dhbase.IntegrationTestDDLMasterFailover.numThreads=20 -Dhbase.IntegrationTestDDLMasterFailover.numRegions=50 --monkey masterKilling
Modifier and Type | Field and Description |
---|---|
protected HBaseCluster |
cluster |
protected Connection |
connection |
protected java.util.concurrent.atomic.AtomicBoolean |
create_table |
protected static int |
DEFAULT_NUM_REGIONS |
protected static int |
DEFAULT_NUM_THREADS |
protected static long |
DEFAULT_RUN_TIME |
protected static java.lang.String |
NUM_REGIONS_KEY |
protected static java.lang.String |
NUM_THREADS_KEY |
protected int |
numRegions |
protected int |
numThreads |
protected static java.lang.String |
RUN_TIME_KEY
A soft limit on how long we should run
|
protected java.util.concurrent.atomic.AtomicBoolean |
running |
CHAOS_MONKEY_PROPS, monkey, MONKEY_LONG_OPT, monkeyProps, monkeyToUse, NO_CLUSTER_CLEANUP_LONG_OPT, noClusterCleanUp, util
Constructor and Description |
---|
IntegrationTestDDLMasterFailover() |
Modifier and Type | Method and Description |
---|---|
void |
cleanUpCluster() |
protected java.util.Set<java.lang.String> |
getColumnFamilies()
Provides the name of the CFs that are protected from random Chaos monkey activity (alter)
|
protected Connection |
getConnection() |
protected int |
getMinServerCount() |
TableName |
getTablename()
Provides the name of the table that is protected from random Chaos monkey activity
|
static void |
main(java.lang.String[] args) |
int |
runTestFromCommandLine() |
protected void |
setConnection(Connection connection) |
void |
setUpCluster() |
void |
testAsUnitTest() |
protected void |
verifyNamespaces() |
protected void |
verifyTables() |
addOptions, cleanUp, cleanUpMonkey, cleanUpMonkey, doWork, getConf, getDefaultMonkeyFactory, getTestingUtil, processBaseOptions, processOptions, setUp, setUpMonkey, startMonkey
protected static final long DEFAULT_RUN_TIME
protected static final int DEFAULT_NUM_THREADS
protected static final int DEFAULT_NUM_REGIONS
protected HBaseCluster cluster
protected Connection connection
protected static final java.lang.String RUN_TIME_KEY
protected static final java.lang.String NUM_THREADS_KEY
protected static final java.lang.String NUM_REGIONS_KEY
protected java.util.concurrent.atomic.AtomicBoolean running
protected java.util.concurrent.atomic.AtomicBoolean create_table
protected int numThreads
protected int numRegions
public void setUpCluster() throws java.lang.Exception
setUpCluster
in class IntegrationTestBase
java.lang.Exception
public void cleanUpCluster() throws java.lang.Exception
cleanUpCluster
in class IntegrationTestBase
java.lang.Exception
protected int getMinServerCount()
protected void setConnection(Connection connection)
protected Connection getConnection()
protected void verifyNamespaces() throws java.io.IOException
java.io.IOException
protected void verifyTables() throws java.io.IOException
java.io.IOException
public void testAsUnitTest() throws java.lang.Exception
java.lang.Exception
public int runTestFromCommandLine() throws java.lang.Exception
runTestFromCommandLine
in class IntegrationTestBase
java.lang.Exception
public TableName getTablename()
IntegrationTestBase
getTablename
in class IntegrationTestBase
protected java.util.Set<java.lang.String> getColumnFamilies()
IntegrationTestBase
getColumnFamilies
in class IntegrationTestBase
public static void main(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception