org.apache.hadoop.hbase.master

Class TestRegionPlacement

java.lang.Object

org.apache.hadoop.hbase.master.TestRegionPlacement

public class TestRegionPlacement
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
private static org.apache.hadoop.hbase.client.Admin	admin
static HBaseClassTestRule	CLASS_RULE
private static org.apache.hadoop.hbase.client.Connection	CONNECTION
private Map<org.apache.hadoop.hbase.client.RegionInfo,org.apache.hadoop.hbase.ServerName[]>	favoredNodesAssignmentPlan
private int	lastRegionOnPrimaryRSCount
private static org.slf4j.Logger	LOG
private static org.apache.hadoop.hbase.favored.FavoredNodesPlan.Position[]	positions
private int	REGION_NUM
private static org.apache.hadoop.hbase.master.RegionPlacementMaintainer	rp
private static int	SLAVES
private static HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor and Description
TestRegionPlacement()

Method Summary

Modifier and Type	Method and Description
private static void	createTable(org.apache.hadoop.hbase.TableName tableName, int regionNum) Create a table with specified table name and region number.
private int	getNumRegionisOnPrimaryRS() Check whether regions are assigned to servers consistent with the explicit hints that are persisted in the hbase:meta table.
private void	killRandomServerAndVerifyAssignment()
static void	setupBeforeClass()
private org.apache.hadoop.hbase.favored.FavoredNodesPlan	shuffleAssignmentPlan(org.apache.hadoop.hbase.favored.FavoredNodesPlan plan, org.apache.hadoop.hbase.favored.FavoredNodesPlan.Position p1, org.apache.hadoop.hbase.favored.FavoredNodesPlan.Position p2) Shuffle the assignment plan by switching two favored node positions.
static void	tearDownAfterClass()
void	testRandomizedMatrix() Used to test the correctness of this class.
void	testRegionPlacement()
private void	verifyMETAUpdated(org.apache.hadoop.hbase.favored.FavoredNodesPlan expectedPlan) Verify the meta has updated to the latest assignment plan
private void	verifyRegionAssignment(org.apache.hadoop.hbase.favored.FavoredNodesPlan plan, int regionMovementNum, int numRegionsOnPrimaryRS) To verify the region assignment status.
private void	verifyRegionMovementNum(int expected) Verify the number of region movement is expected
private void	verifyRegionOnPrimaryRS(int expectedNum) Verify the number of user regions is assigned to the primary region server based on the plan is expected
private void	verifyRegionServerUpdated(org.apache.hadoop.hbase.favored.FavoredNodesPlan plan) Verify all the online region servers has been updated to the latest assignment plan

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

LOG

private static final org.slf4j.Logger LOG

TEST_UTIL

private static final HBaseTestingUtility TEST_UTIL

SLAVES

private static final int SLAVES

See Also:

Constant Field Values

CONNECTION

private static org.apache.hadoop.hbase.client.Connection CONNECTION

admin

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

rp

private static org.apache.hadoop.hbase.master.RegionPlacementMaintainer rp

positions

private static org.apache.hadoop.hbase.favored.FavoredNodesPlan.Position[] positions

lastRegionOnPrimaryRSCount

private int lastRegionOnPrimaryRSCount

REGION_NUM

private int REGION_NUM

favoredNodesAssignmentPlan

private Map<org.apache.hadoop.hbase.client.RegionInfo,org.apache.hadoop.hbase.ServerName[]> favoredNodesAssignmentPlan

Constructor Detail

TestRegionPlacement

public TestRegionPlacement()

Method Detail

setupBeforeClass

public static void setupBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

testRegionPlacement

public void testRegionPlacement()
                         throws Exception

Throws:

Exception

killRandomServerAndVerifyAssignment

private void killRandomServerAndVerifyAssignment()
                                          throws IOException,
                                                 InterruptedException,
                                                 org.apache.zookeeper.KeeperException

Throws:

IOException

InterruptedException

org.apache.zookeeper.KeeperException

testRandomizedMatrix

public void testRandomizedMatrix()

Used to test the correctness of this class.

shuffleAssignmentPlan

private org.apache.hadoop.hbase.favored.FavoredNodesPlan shuffleAssignmentPlan(org.apache.hadoop.hbase.favored.FavoredNodesPlan plan,
                                                                               org.apache.hadoop.hbase.favored.FavoredNodesPlan.Position p1,
                                                                               org.apache.hadoop.hbase.favored.FavoredNodesPlan.Position p2)
                                                                        throws IOException

Shuffle the assignment plan by switching two favored node positions.

Parameters:

plan - The assignment plan

p1 - The first switch position

p2 - The second switch position

Returns:

the shuffled assignment plan

Throws:

IOException

verifyRegionAssignment

private void verifyRegionAssignment(org.apache.hadoop.hbase.favored.FavoredNodesPlan plan,
                                    int regionMovementNum,
                                    int numRegionsOnPrimaryRS)
                             throws InterruptedException,
                                    IOException

To verify the region assignment status. It will check the assignment plan consistency between hbase:meta and region servers. Also it will verify weather the number of region movement and the number regions on the primary region server are expected

Parameters:

plan -

regionMovementNum -

numRegionsOnPrimaryRS -

Throws:

InterruptedException

IOException

verifyMETAUpdated

private void verifyMETAUpdated(org.apache.hadoop.hbase.favored.FavoredNodesPlan expectedPlan)
                        throws IOException

Verify the meta has updated to the latest assignment plan

Parameters:

expectedPlan - the region assignment plan

Throws:

IOException - if an IO problem is encountered

verifyRegionMovementNum

private void verifyRegionMovementNum(int expected)
                              throws InterruptedException,
                                     IOException

Verify the number of region movement is expected

Throws:

InterruptedException

IOException

verifyRegionOnPrimaryRS

private void verifyRegionOnPrimaryRS(int expectedNum)
                              throws IOException

Verify the number of user regions is assigned to the primary region server based on the plan is expected

Parameters:

expectedNum - the expected number of assigned regions

Throws:

IOException

verifyRegionServerUpdated

private void verifyRegionServerUpdated(org.apache.hadoop.hbase.favored.FavoredNodesPlan plan)
                                throws IOException

Verify all the online region servers has been updated to the latest assignment plan

Parameters:

plan -

Throws:

IOException

getNumRegionisOnPrimaryRS

private int getNumRegionisOnPrimaryRS()
                               throws IOException

Check whether regions are assigned to servers consistent with the explicit hints that are persisted in the hbase:meta table. Also keep track of the number of the regions are assigned to the primary region server.

Returns:

the number of regions are assigned to the primary region server

Throws:

IOException

createTable

private static void createTable(org.apache.hadoop.hbase.TableName tableName,
                                int regionNum)
                         throws IOException

Create a table with specified table name and region number.

Parameters:

tableName - the name of the table to be created

regionNum - number of regions to create

Throws:

IOException