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

@Tag("org.apache.hadoop.hbase.testclassification.RSGroupTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestRSGroupsAdmin2
extends TestRSGroupsBase

Nested Class Summary

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

TestRSGroupsBase.CPMasterObserver, TestRSGroupsBase.MethodName

Field Summary

Fields

Modifier and Type	Field	Description
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(org.junit.jupiter.api.TestInfo testInfo)
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

LOG

private static final org.slf4j.Logger LOG

Constructor Details

TestRSGroupsAdmin2

public TestRSGroupsAdmin2()

Method Details

setUp

@BeforeAll
public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

@AfterAll
public static void tearDown()
                     throws Exception

Throws:

Exception

beforeMethod

@BeforeEach
public void beforeMethod(org.junit.jupiter.api.TestInfo testInfo)
                  throws Exception

Throws:

Exception

afterMethod

@AfterEach
public void afterMethod()
                 throws Exception

Throws:

Exception

testRegionMove

@Test
public void testRegionMove()
                    throws Exception

Throws:

Exception

testRegionServerMove

@Test
public void testRegionServerMove()
                          throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testMoveServers

@Test
public void testMoveServers()
                     throws Exception

Throws:

Exception

testRemoveServers

@Test
public void testRemoveServers()
                       throws Exception

Throws:

Exception

testMoveServersAndTables

@Test
public void testMoveServersAndTables()
                              throws Exception

Throws:

Exception

testMoveServersFromDefaultGroup

@Test
public void testMoveServersFromDefaultGroup()
                                     throws Exception

Throws:

Exception

testFailedMoveBeforeRetryExhaustedWhenMoveServer

@Test
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

@Test
public void testFailedMoveServersAndRepair()
                                    throws Exception

Throws:

Exception

testFailedMoveServersTablesAndRepair

@Test
public void testFailedMoveServersTablesAndRepair()
                                          throws Exception

Throws:

Exception

testMoveServersToRSGroupPerformance

@Test
public void testMoveServersToRSGroupPerformance()
                                         throws Exception

Throws:

Exception