Package org.apache.hadoop.hbase.master.assignment

Class TestMergeTableRegionsProcedure

java.lang.Object

org.apache.hadoop.hbase.master.assignment.TestMergeTableRegionsProcedure

@Tag("org.apache.hadoop.hbase.testclassification.MasterTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestMergeTableRegionsProcedure
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static org.apache.hadoop.hbase.client.Admin	admin
private long	assignFailedCount
private org.apache.hadoop.hbase.procedure2.ProcedureMetrics	assignProcMetrics
private long	assignSubmittedCount
private static final byte[]	FAMILY
private static final int	initialRegionCount
private static final org.slf4j.Logger	LOG
private long	mergeFailedCount
private org.apache.hadoop.hbase.procedure2.ProcedureMetrics	mergeProcMetrics
private long	mergeSubmittedCount
private String	testMethodName
private long	unassignFailedCount
private org.apache.hadoop.hbase.procedure2.ProcedureMetrics	unassignProcMetrics
private long	unassignSubmittedCount
private static final HBaseTestingUtil	UTIL

Constructor Summary

Constructors

Constructor	Description
TestMergeTableRegionsProcedure()

Method Summary

Modifier and Type	Method	Description
List<org.apache.hadoop.hbase.client.RegionInfo>	assertRegionCount(org.apache.hadoop.hbase.TableName tableName, int nregions)
static void	cleanupTest()
private void	collectAssignmentManagerMetrics()
private List<org.apache.hadoop.hbase.client.RegionInfo>	createTable(org.apache.hadoop.hbase.TableName tableName)
private org.apache.hadoop.hbase.procedure2.ProcedureExecutor<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>	getMasterProcedureExecutor()
private int	loadARowPerRegion(org.apache.hadoop.hbase.client.Table t, List<org.apache.hadoop.hbase.client.RegionInfo> ris)
private void	resetProcExecutorTestingKillFlag()
void	setTestMethod(org.junit.jupiter.api.TestInfo testInfo)
void	setup()
static void	setupCluster()
private static void	setupConf(org.apache.hadoop.conf.Configuration conf)
void	tearDown()
private void	testMerge(org.apache.hadoop.hbase.TableName tableName, int mergeCount)
void	testMergeDetectsModifyTableProcedure()
void	testMergeRegionsConcurrently()	This tests two concurrent region merges
void	testMergeTenRegions()	This tests ten region merges in one go.
void	testMergeTwoRegions()	This tests two region merges
void	testMergeWithoutPONR()
void	testMergingRegionWhileTakingSnapshot()
void	testRecoveryAndDoubleExecution()
void	testRollbackAndDoubleExecution()

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

testMethodName

private String testMethodName

UTIL

private static final HBaseTestingUtil UTIL

initialRegionCount

private static final int initialRegionCount

See Also:

• Constant Field Values

FAMILY

private static final byte[] FAMILY

admin

private static org.apache.hadoop.hbase.client.Admin admin

mergeProcMetrics

private org.apache.hadoop.hbase.procedure2.ProcedureMetrics mergeProcMetrics

assignProcMetrics

private org.apache.hadoop.hbase.procedure2.ProcedureMetrics assignProcMetrics

unassignProcMetrics

private org.apache.hadoop.hbase.procedure2.ProcedureMetrics unassignProcMetrics

mergeSubmittedCount

private long mergeSubmittedCount

mergeFailedCount

private long mergeFailedCount

assignSubmittedCount

private long assignSubmittedCount

assignFailedCount

private long assignFailedCount

unassignSubmittedCount

private long unassignSubmittedCount

unassignFailedCount

private long unassignFailedCount

Constructor Details

TestMergeTableRegionsProcedure

public TestMergeTableRegionsProcedure()

Method Details

setupConf

private static void setupConf(org.apache.hadoop.conf.Configuration conf)

setupCluster

@BeforeAll
public static void setupCluster()
                         throws Exception

Throws:

Exception

cleanupTest

@AfterAll
public static void cleanupTest()
                        throws Exception

Throws:

Exception

setup

@BeforeEach
public void setup()
           throws Exception

Throws:

Exception

setTestMethod

@BeforeEach
public void setTestMethod(org.junit.jupiter.api.TestInfo testInfo)

tearDown

@AfterEach
public void tearDown()
              throws Exception

Throws:

Exception

resetProcExecutorTestingKillFlag

private void resetProcExecutorTestingKillFlag()

loadARowPerRegion

private int loadARowPerRegion(org.apache.hadoop.hbase.client.Table t,
 List<org.apache.hadoop.hbase.client.RegionInfo> ris)
                       throws IOException

Throws:

IOException

testMergeTwoRegions

@Test
public void testMergeTwoRegions()
                         throws Exception

This tests two region merges

Throws:

Exception

testMerge

private void testMerge(org.apache.hadoop.hbase.TableName tableName,
 int mergeCount)
                throws IOException

Throws:

IOException

testMergeTenRegions

@Test
public void testMergeTenRegions()
                         throws Exception

This tests ten region merges in one go.

Throws:

Exception

testMergeRegionsConcurrently

@Test
public void testMergeRegionsConcurrently()
                                  throws Exception

This tests two concurrent region merges

Throws:

Exception

testRecoveryAndDoubleExecution

@Test
public void testRecoveryAndDoubleExecution()
                                    throws Exception

Throws:

Exception

testRollbackAndDoubleExecution

@Test
public void testRollbackAndDoubleExecution()
                                    throws Exception

Throws:

Exception

testMergeWithoutPONR

@Test
public void testMergeWithoutPONR()
                          throws Exception

Throws:

Exception

testMergingRegionWhileTakingSnapshot

@Test
public void testMergingRegionWhileTakingSnapshot()
                                          throws Exception

Throws:

Exception

testMergeDetectsModifyTableProcedure

@Test
public void testMergeDetectsModifyTableProcedure()
                                          throws Exception

Throws:

Exception

createTable

private List<org.apache.hadoop.hbase.client.RegionInfo> createTable(org.apache.hadoop.hbase.TableName tableName)
                                                             throws Exception

Throws:

Exception

assertRegionCount

public List<org.apache.hadoop.hbase.client.RegionInfo> assertRegionCount(org.apache.hadoop.hbase.TableName tableName,
 int nregions)
                                                                  throws Exception

Throws:

Exception

getMasterProcedureExecutor

private org.apache.hadoop.hbase.procedure2.ProcedureExecutor<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv> getMasterProcedureExecutor()

collectAssignmentManagerMetrics

private void collectAssignmentManagerMetrics()