Package org.apache.hadoop.hbase

Class TestRegionRebalancing

java.lang.Object

org.apache.hadoop.hbase.TestRegionRebalancing

public class TestRegionRebalancing
extends Object

Test whether region re-balancing works. (HBASE-71) The test only works for cluster wide balancing, not per table wide. Increase the margin a little to make StochasticLoadBalancer result acceptable.

Field Summary

Fields

Modifier and Type	Field	Description
private String	balancerName
static final HBaseClassTestRule	CLASS_RULE
private static final byte[]	FAMILY_NAME
private static final org.slf4j.Logger	LOG
private org.apache.hadoop.hbase.client.RegionLocator	regionLocator
private org.apache.hadoop.hbase.client.TableDescriptor	tableDescriptor
private final HBaseTestingUtil	UTIL

Constructor Summary

Constructors

Constructor	Description
TestRegionRebalancing(String balancerName)

Method Summary

Modifier and Type	Method	Description
void	after()
private void	assertRegionsAreBalanced()	Determine if regions are balanced.
void	before()
static Collection<Object[]>	data()
private List<org.apache.hadoop.hbase.regionserver.HRegionServer>	getOnlineRegionServers()
void	testRebalanceOnRegionServerNumberChange()	For HBASE-71.
private void	waitForAllRegionsAssigned()	Wait until all the regions are assigned.
private void	waitOnCrashProcessing()	Wait on crash processing.

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

FAMILY_NAME

private static final byte[] FAMILY_NAME

LOG

private static final org.slf4j.Logger LOG

UTIL

private final HBaseTestingUtil UTIL

regionLocator

private org.apache.hadoop.hbase.client.RegionLocator regionLocator

tableDescriptor

private org.apache.hadoop.hbase.client.TableDescriptor tableDescriptor

balancerName

private String balancerName

Constructor Details

TestRegionRebalancing

public TestRegionRebalancing(String balancerName)

Method Details

data

public static Collection<Object[]> data()

after

public void after()
           throws Exception

Throws:

Exception

before

public void before()
            throws Exception

Throws:

Exception

testRebalanceOnRegionServerNumberChange

public void testRebalanceOnRegionServerNumberChange()
                                             throws IOException,
InterruptedException

For HBASE-71. Try a few different configurations of starting and stopping region servers to see if the assignment or regions is pretty balanced.

Throws:

IOException

InterruptedException

waitOnCrashProcessing

private void waitOnCrashProcessing()
                            throws IOException

Wait on crash processing. Balancer won't run if processing a crashed server.

Throws:

IOException

assertRegionsAreBalanced

private void assertRegionsAreBalanced()
                               throws IOException

Determine if regions are balanced. Figure out the total, divide by the number of online servers, then test if each server is +/- 1 of average rounded up.

Throws:

IOException

getOnlineRegionServers

private List<org.apache.hadoop.hbase.regionserver.HRegionServer> getOnlineRegionServers()

waitForAllRegionsAssigned

private void waitForAllRegionsAssigned()
                                throws IOException

Wait until all the regions are assigned.

Throws:

IOException