Package org.apache.hadoop.hbase.master.balancer

Class TestBaseLoadBalancer

java.lang.Object

org.apache.hadoop.hbase.master.balancer.BalancerTestBase

org.apache.hadoop.hbase.master.balancer.TestBaseLoadBalancer

@Tag("org.apache.hadoop.hbase.testclassification.MasterTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
public class TestBaseLoadBalancer
extends BalancerTestBase

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestBaseLoadBalancer.MockBalancer

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.master.balancer.BalancerTestBase

BalancerTestBase.MockMapping

Field Summary

Fields

Modifier and Type	Field	Description
private static org.apache.hadoop.hbase.master.LoadBalancer	loadBalancer
private static final org.slf4j.Logger	LOG
private static final org.apache.hadoop.hbase.ServerName	master
private String	methodName
private static final int	NUM_SERVERS
private static org.apache.hadoop.hbase.master.RackManager	rackManager
(package private) int[][]	regionsAndServersMocks
private static final org.apache.hadoop.hbase.ServerName[]	servers

Fields inherited from class org.apache.hadoop.hbase.master.balancer.BalancerTestBase

clusterStateMocks, clusterStateMocksWithNoSlop, clusterStateMocksWithSlop, conf, largeCluster, regionId

Constructor Summary

Constructors

Constructor	Description
TestBaseLoadBalancer()

Method Summary

Modifier and Type	Method	Description
private void	assertRetainedAssignment(Map<org.apache.hadoop.hbase.client.RegionInfo,org.apache.hadoop.hbase.ServerName> existing, List<org.apache.hadoop.hbase.ServerName> servers, Map<org.apache.hadoop.hbase.ServerName,List<org.apache.hadoop.hbase.client.RegionInfo>> assignment)	Asserts a valid retained assignment plan.
private void	assignRegions(List<org.apache.hadoop.hbase.client.RegionInfo> regions, List<org.apache.hadoop.hbase.ServerName> servers, Map<org.apache.hadoop.hbase.ServerName,List<org.apache.hadoop.hbase.client.RegionInfo>> clusterState)
static void	beforeAllTests()
private List<org.apache.hadoop.hbase.ServerName>	getListOfServerNames(List<org.apache.hadoop.hbase.master.balancer.ServerAndLoad> sals)
void	setUpBeforeEach(org.junit.jupiter.api.TestInfo testInfo)
void	testBulkAssignment()	Tests the bulk assignment used during cluster startup.
void	testClusterRegionLocations()
void	testClusterServersWithSameHostPort()
void	testRandomAssignment()
private void	testRandomAssignment(int numberOfIdleServers)
void	testRegionAvailability()
void	testRegionAvailabilityWithRegionMoves()
void	testRetainAssignment()	Test the cluster startup bulk assignment which attempts to retain assignment info.

Methods inherited from class org.apache.hadoop.hbase.master.balancer.BalancerTestBase

assertClusterAsBalanced, assertClusterOverallAsBalanced, assertRegionReplicaPlacement, convertToList, createRegions, createServerMap, mockCluster, mockClusterServers, mockClusterServers, mockClusterServers, mockClusterServersUnsorted, mockClusterServersWithTables, mockUniformClusterServers, printMock, printStats, randomRegions, randomRegions, randomServer, randomServers, reconcile, returnRegions, returnServer, returnServers, uniformRegions, updateLoad

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

loadBalancer

private static org.apache.hadoop.hbase.master.LoadBalancer loadBalancer

LOG

private static final org.slf4j.Logger LOG

master

private static final org.apache.hadoop.hbase.ServerName master

rackManager

private static org.apache.hadoop.hbase.master.RackManager rackManager

NUM_SERVERS

private static final int NUM_SERVERS

See Also:

• Constant Field Values

servers

private static final org.apache.hadoop.hbase.ServerName[] servers

regionsAndServersMocks

int[][] regionsAndServersMocks

methodName

private String methodName

Constructor Details

TestBaseLoadBalancer

public TestBaseLoadBalancer()

Method Details

beforeAllTests

@BeforeAll
public static void beforeAllTests()
                           throws Exception

Throws:

Exception

setUpBeforeEach

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

Throws:

Exception

testBulkAssignment

@Test
public void testBulkAssignment()
                        throws Exception

Tests the bulk assignment used during cluster startup. Round-robin. Should yield a balanced cluster so same invariant as the load balancer holds, all servers holding either floor(avg) or ceiling(avg).

Throws:

Exception

testRetainAssignment

@Test
public void testRetainAssignment()
                          throws Exception

Test the cluster startup bulk assignment which attempts to retain assignment info.

Throws:

Exception

testRandomAssignment

@Test
public void testRandomAssignment()
                          throws Exception

Throws:

Exception

testRandomAssignment

private void testRandomAssignment(int numberOfIdleServers)
                           throws Exception

Throws:

Exception

testRegionAvailability

@Test
public void testRegionAvailability()
                            throws Exception

Throws:

Exception

testRegionAvailabilityWithRegionMoves

@Test
public void testRegionAvailabilityWithRegionMoves()
                                           throws Exception

Throws:

Exception

getListOfServerNames

private List<org.apache.hadoop.hbase.ServerName> getListOfServerNames(List<org.apache.hadoop.hbase.master.balancer.ServerAndLoad> sals)

assertRetainedAssignment

private void assertRetainedAssignment(Map<org.apache.hadoop.hbase.client.RegionInfo,org.apache.hadoop.hbase.ServerName> existing,
 List<org.apache.hadoop.hbase.ServerName> servers,
 Map<org.apache.hadoop.hbase.ServerName,List<org.apache.hadoop.hbase.client.RegionInfo>> assignment)

Asserts a valid retained assignment plan.

Must meet the following conditions:

• Every input region has an assignment, and to an online server
• If a region had an existing assignment to a server with the same address a a currently online server, it will be assigned to it

testClusterServersWithSameHostPort

@Test
public void testClusterServersWithSameHostPort()

assignRegions

private void assignRegions(List<org.apache.hadoop.hbase.client.RegionInfo> regions,
 List<org.apache.hadoop.hbase.ServerName> servers,
 Map<org.apache.hadoop.hbase.ServerName,List<org.apache.hadoop.hbase.client.RegionInfo>> clusterState)

testClusterRegionLocations

@Test
public void testClusterRegionLocations()