org.apache.hadoop.hbase.master

Class TestRecreateCluster

java.lang.Object

org.apache.hadoop.hbase.master.TestRecreateCluster

public class TestRecreateCluster
extends Object

Test reuse storefiles within data directory when cluster failover with a set of new region servers with different hostnames with or without WALs and Zookeeper ZNodes, the master and cluster should fail respectively if there is any situation considered as not supported.

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static long	MASTER_INIT_TIMEOUT_MS
org.junit.rules.TestName	name
private static int	NUM_RS
private static HBaseTestingUtility	TEST_UTIL
private static long	TIMEOUT_MS

Constructor Summary

Constructors

Constructor and Description
TestRecreateCluster()

Method Summary

Modifier and Type	Method and Description
private void	ensureTableNotColocatedWithSystemTable(org.apache.hadoop.hbase.TableName userTable, org.apache.hadoop.hbase.TableName systemTable)
private int	getServerNumForTableWithOnlyOneRegion(org.apache.hadoop.hbase.TableName tableName)
private void	prepareDataBeforeRecreate(HBaseTestingUtility testUtil, org.apache.hadoop.hbase.TableName tableName)
private void	restartHBaseCluster(boolean cleanUpWALs, boolean cleanUpZnodes)
void	setup()
void	testRecreateCluster_UserTableDisabled_ReuseWALsAndZNodes()
void	testRecreateCluster_UserTableEnabled_CleanupWALAndZNodes()
void	testRecreateCluster_UserTableEnabled_CleanupZNodes()
void	testRecreateCluster_UserTableEnabled_ReuseWALsAndZNodes()
private void	validateDataAfterRecreate(HBaseTestingUtility testUtil, org.apache.hadoop.hbase.TableName tableName)
private void	validateRecreateClusterWithUserDisabled(boolean cleanupWALs, boolean cleanUpZNodes)
private void	validateRecreateClusterWithUserTableEnabled(boolean cleanupWALs, boolean cleanUpZNodes)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

name

public org.junit.rules.TestName name

TEST_UTIL

private static final HBaseTestingUtility TEST_UTIL

NUM_RS

private static final int NUM_RS

See Also:

Constant Field Values

TIMEOUT_MS

private static final long TIMEOUT_MS

MASTER_INIT_TIMEOUT_MS

private static final long MASTER_INIT_TIMEOUT_MS

Constructor Detail

TestRecreateCluster

public TestRecreateCluster()

Method Detail

setup

public void setup()

testRecreateCluster_UserTableDisabled_ReuseWALsAndZNodes

public void testRecreateCluster_UserTableDisabled_ReuseWALsAndZNodes()
                                                              throws Exception

Throws:

Exception

testRecreateCluster_UserTableEnabled_ReuseWALsAndZNodes

public void testRecreateCluster_UserTableEnabled_ReuseWALsAndZNodes()
                                                             throws Exception

Throws:

Exception

testRecreateCluster_UserTableEnabled_CleanupZNodes

public void testRecreateCluster_UserTableEnabled_CleanupZNodes()
                                                        throws Exception

Throws:

Exception

testRecreateCluster_UserTableEnabled_CleanupWALAndZNodes

public void testRecreateCluster_UserTableEnabled_CleanupWALAndZNodes()
                                                              throws Exception

Throws:

Exception

validateRecreateClusterWithUserDisabled

private void validateRecreateClusterWithUserDisabled(boolean cleanupWALs,
                                                     boolean cleanUpZNodes)
                                              throws Exception

Throws:

Exception

validateRecreateClusterWithUserTableEnabled

private void validateRecreateClusterWithUserTableEnabled(boolean cleanupWALs,
                                                         boolean cleanUpZNodes)
                                                  throws Exception

Throws:

Exception

restartHBaseCluster

private void restartHBaseCluster(boolean cleanUpWALs,
                                 boolean cleanUpZnodes)
                          throws Exception

Throws:

Exception

prepareDataBeforeRecreate

private void prepareDataBeforeRecreate(HBaseTestingUtility testUtil,
                                       org.apache.hadoop.hbase.TableName tableName)
                                throws Exception

Throws:

Exception

ensureTableNotColocatedWithSystemTable

private void ensureTableNotColocatedWithSystemTable(org.apache.hadoop.hbase.TableName userTable,
                                                    org.apache.hadoop.hbase.TableName systemTable)
                                             throws IOException,
                                                    InterruptedException

Throws:

IOException

InterruptedException

getServerNumForTableWithOnlyOneRegion

private int getServerNumForTableWithOnlyOneRegion(org.apache.hadoop.hbase.TableName tableName)
                                           throws IOException

Throws:

IOException

validateDataAfterRecreate

private void validateDataAfterRecreate(HBaseTestingUtility testUtil,
                                       org.apache.hadoop.hbase.TableName tableName)
                                throws Exception

Throws:

Exception