Package org.apache.hadoop.hbase.rsgroup

Class TestRSGroupsAdmin2

java.lang.Object

org.apache.hadoop.hbase.client.AbstractTestUpdateConfiguration

org.apache.hadoop.hbase.rsgroup.TestRSGroupsBase

org.apache.hadoop.hbase.rsgroup.TestRSGroupsAdmin2

public class TestRSGroupsAdmin2
extends TestRSGroupsBase

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.rsgroup.TestRSGroupsBase

TestRSGroupsBase.CPMasterObserver

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static final org.slf4j.Logger	LOG

Fields inherited from class org.apache.hadoop.hbase.rsgroup.TestRSGroupsBase

ADMIN, CLUSTER, GROUP_PREFIX, INIT, MASTER, name, NUM_DEAD_SERVERS, NUM_SLAVES_BASE, OBSERVER, TABLE_PREFIX, tableName, TEST_UTIL, WAIT_TIMEOUT

Constructor Summary

Constructors

Constructor	Description
TestRSGroupsAdmin2()

Method Summary

Modifier and Type	Method	Description
void	afterMethod()
void	beforeMethod()
private org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.hbase.ServerName,org.apache.hadoop.hbase.master.assignment.RegionStateNode>	createTableWithRegionSplitting(org.apache.hadoop.hbase.rsgroup.RSGroupInfo rsGroupInfo, int tableRegionCount)
private org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.hbase.ServerName,org.apache.hadoop.hbase.master.assignment.RegionStateNode>	randomlySetOneRegionStateToSplitting(org.apache.hadoop.hbase.rsgroup.RSGroupInfo newGroup)	Randomly choose a region to set state.
private org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.hbase.ServerName,org.apache.hadoop.hbase.master.assignment.RegionStateNode>	randomlySetRegionState(org.apache.hadoop.hbase.rsgroup.RSGroupInfo groupInfo, org.apache.hadoop.hbase.master.RegionState.State state, org.apache.hadoop.hbase.TableName... tableNames)
private <T> Thread	recoverRegionStateThread(T owner, Function<T,List<org.apache.hadoop.hbase.client.RegionInfo>> getRegions, org.apache.hadoop.hbase.master.assignment.RegionStateNode rsn, AtomicBoolean changed)
static void	setUp()
static void	tearDown()
void	testFailedMoveBeforeRetryExhaustedWhenMoveServer()
void	testFailedMoveServersAndRepair()
void	testFailedMoveServersTablesAndRepair()
void	testMoveServers()
void	testMoveServersAndTables()
void	testMoveServersFromDefaultGroup()
void	testMoveServersToRSGroupPerformance()
void	testRegionMove()
void	testRegionServerMove()
void	testRemoveServers()

Methods inherited from class org.apache.hadoop.hbase.rsgroup.TestRSGroupsBase

addGroup, deleteGroups, deleteNamespaceIfNecessary, deleteTableIfNecessary, getGroupName, getNameWithoutIndex, getNumServers, getServerName, getTableRegionMap, getTableServerRegionMap, initialize, removeGroup, setUpBeforeMethod, setUpTestBeforeClass, tearDownAfterClass, tearDownAfterMethod, toggleQuotaCheckAndRestartMiniCluster

Methods inherited from class org.apache.hadoop.hbase.client.AbstractTestUpdateConfiguration

addResourceToRegionServerConfiguration, replaceHBaseSiteXML, restoreHBaseSiteXML, setUpConfigurationFiles

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

Constructor Details

TestRSGroupsAdmin2

public TestRSGroupsAdmin2()

Method Details

setUp

public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

public static void tearDown()
                     throws Exception

Throws:

Exception

beforeMethod

public void beforeMethod()
                  throws Exception

Throws:

Exception

afterMethod

public void afterMethod()
                 throws Exception

Throws:

Exception

testRegionMove

public void testRegionMove()
                    throws Exception

Throws:

Exception

testRegionServerMove

public void testRegionServerMove()
                          throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testMoveServers

public void testMoveServers()
                     throws Exception

Throws:

Exception

testRemoveServers

public void testRemoveServers()
                       throws Exception

Throws:

Exception

testMoveServersAndTables

public void testMoveServersAndTables()
                              throws Exception

Throws:

Exception

testMoveServersFromDefaultGroup

public void testMoveServersFromDefaultGroup()
                                     throws Exception

Throws:

Exception

testFailedMoveBeforeRetryExhaustedWhenMoveServer

public void testFailedMoveBeforeRetryExhaustedWhenMoveServer()
                                                      throws Exception

Throws:

Exception

recoverRegionStateThread

private <T> Thread recoverRegionStateThread(T owner,
 Function<T,List<org.apache.hadoop.hbase.client.RegionInfo>> getRegions,
 org.apache.hadoop.hbase.master.assignment.RegionStateNode rsn,
 AtomicBoolean changed)

createTableWithRegionSplitting

private org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.hbase.ServerName,org.apache.hadoop.hbase.master.assignment.RegionStateNode> createTableWithRegionSplitting(org.apache.hadoop.hbase.rsgroup.RSGroupInfo rsGroupInfo,
 int tableRegionCount)
                                                                                                                                                                throws Exception

Throws:

Exception

randomlySetOneRegionStateToSplitting

private org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.hbase.ServerName,org.apache.hadoop.hbase.master.assignment.RegionStateNode> randomlySetOneRegionStateToSplitting(org.apache.hadoop.hbase.rsgroup.RSGroupInfo newGroup)
                                                                                                                                                                      throws IOException

Randomly choose a region to set state.

Parameters:

newGroup - target group

Returns:

source server of region, and region state

Throws:

IOException - if methods called throw

randomlySetRegionState

private org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.hbase.ServerName,org.apache.hadoop.hbase.master.assignment.RegionStateNode> randomlySetRegionState(org.apache.hadoop.hbase.rsgroup.RSGroupInfo groupInfo,
 org.apache.hadoop.hbase.master.RegionState.State state,
 org.apache.hadoop.hbase.TableName... tableNames)
                                                                                                                                                        throws IOException

Throws:

IOException

testFailedMoveServersAndRepair

public void testFailedMoveServersAndRepair()
                                    throws Exception

Throws:

Exception

testFailedMoveServersTablesAndRepair

public void testFailedMoveServersTablesAndRepair()
                                          throws Exception

Throws:

Exception

testMoveServersToRSGroupPerformance

public void testMoveServersToRSGroupPerformance()
                                         throws Exception

Throws:

Exception