Package org.apache.hadoop.hbase

Class TestRegionRebalancing

java.lang.Object

org.apache.hadoop.hbase.TestRegionRebalancing

@Tag("org.apache.hadoop.hbase.testclassification.FlakeyTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
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
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()
private List<org.apache.hadoop.hbase.regionserver.HRegionServer>	getOnlineRegionServers()
static Stream<org.junit.jupiter.params.provider.Arguments>	parameters()
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

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

parameters

public static Stream<org.junit.jupiter.params.provider.Arguments> parameters()

after

@AfterEach
public void after()
           throws Exception

Throws:

Exception

before

@BeforeEach
public void before()
            throws Exception

Throws:

Exception

testRebalanceOnRegionServerNumberChange

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