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

Class TestAssignmentManager

java.lang.Object

org.apache.hadoop.hbase.master.assignment.TestAssignmentManagerBase

org.apache.hadoop.hbase.master.assignment.TestAssignmentManager

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

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.master.assignment.TestAssignmentManagerBase

TestAssignmentManagerBase.CallQueueTooBigOnceRsExecutor, TestAssignmentManagerBase.FaultyRsExecutor, TestAssignmentManagerBase.GoodRsExecutor, TestAssignmentManagerBase.HangOnCloseThenRSCrashExecutor, TestAssignmentManagerBase.HangThenRSCrashExecutor, TestAssignmentManagerBase.HangThenRSRestartExecutor, TestAssignmentManagerBase.MockRSExecutor, TestAssignmentManagerBase.MockRSProcedureDispatcher, TestAssignmentManagerBase.NoopRsExecutor, TestAssignmentManagerBase.RandRsExecutor, TestAssignmentManagerBase.ServerNotYetRunningRsExecutor, TestAssignmentManagerBase.SocketTimeoutRsExecutor, TestAssignmentManagerBase.TimeoutThenCallQueueTooBigRsExecutor

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG

Fields inherited from class org.apache.hadoop.hbase.master.assignment.TestAssignmentManagerBase

am, assignFailedCount, assignProcMetrics, assignSubmittedCount, closeFailedCount, closeProcMetrics, closeSubmittedCount, executor, master, moveFailedCount, moveProcMetrics, moveSubmittedCount, newRsAdded, NREGIONS, NSERVERS, openFailedCount, openProcMetrics, openSubmittedCount, PROC_NTHREADS, regionsToRegionServers, reopenFailedCount, reopenProcMetrics, reopenSubmittedCount, rsDispatcher, testMethodName, unassignFailedCount, unassignProcMetrics, unassignSubmittedCount, util

Constructor Summary

Constructors

Constructor	Description
TestAssignmentManager()

Method Summary

Modifier and Type	Method	Description
private void	assertCloseThenOpen()
private void	testAssign(TestAssignmentManagerBase.MockRSExecutor executor)
private void	testAssign(TestAssignmentManagerBase.MockRSExecutor executor, int nRegions)
void	testAssignAnAssignedRegion()
void	testAssignAndCrashBeforeResponse()
void	testAssignMetaAndCrashBeforeResponse()	It is possible that when AM send assign meta request to a RS successfully, but RS can not send back any response, which cause master startup hangs forever
void	testAssignQueueFullOnce()
void	testAssignSocketTimeout()
void	testAssignWithGoodExec()
void	testLoadRegionFromMetaAfterRegionManuallyAdded()
void	testLoadRegionFromMetaRegionNotInMeta()
void	testMove()
void	testReopen()
void	testTimeoutThenQueueFull()
void	testUnassignAndCrashBeforeResponse()
void	testUnassignAnUnassignedRegion()

Methods inherited from class org.apache.hadoop.hbase.master.assignment.TestAssignmentManagerBase

bulkSubmit, collectAssignmentManagerMetrics, createAndSubmitAssign, createAssignProcedure, createRegionInfo, createUnassignProcedure, doCrash, doRestart, getAssignMaxAttempts, sendTransitionReport, setTestMethod, setUp, setupConfiguration, setUpMeta, submitProcedure, tearDown, waitOnFuture

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

Constructor Details

TestAssignmentManager

public TestAssignmentManager()

Method Details

testAssignWithGoodExec

@Test
public void testAssignWithGoodExec()
                            throws Exception

Throws:

Exception

testAssignAndCrashBeforeResponse

@Test
public void testAssignAndCrashBeforeResponse()
                                      throws Exception

Throws:

Exception

testUnassignAndCrashBeforeResponse

@Test
public void testUnassignAndCrashBeforeResponse()
                                        throws Exception

Throws:

Exception

testAssignSocketTimeout

@Test
public void testAssignSocketTimeout()
                             throws Exception

Throws:

Exception

testAssignQueueFullOnce

@Test
public void testAssignQueueFullOnce()
                             throws Exception

Throws:

Exception

testTimeoutThenQueueFull

@Test
public void testTimeoutThenQueueFull()
                              throws Exception

Throws:

Exception

testAssign

private void testAssign(TestAssignmentManagerBase.MockRSExecutor executor)
                 throws Exception

Throws:

Exception

testAssign

private void testAssign(TestAssignmentManagerBase.MockRSExecutor executor,
 int nRegions)
                 throws Exception

Throws:

Exception

testAssignAnAssignedRegion

@Test
public void testAssignAnAssignedRegion()
                                throws Exception

Throws:

Exception

testUnassignAnUnassignedRegion

@Test
public void testUnassignAnUnassignedRegion()
                                    throws Exception

Throws:

Exception

testAssignMetaAndCrashBeforeResponse

@Test
public void testAssignMetaAndCrashBeforeResponse()
                                          throws Exception

It is possible that when AM send assign meta request to a RS successfully, but RS can not send back any response, which cause master startup hangs forever

Throws:

Exception

assertCloseThenOpen

private void assertCloseThenOpen()

testMove

@Test
public void testMove()
              throws Exception

Throws:

Exception

testReopen

@Test
public void testReopen()
                throws Exception

Throws:

Exception

testLoadRegionFromMetaAfterRegionManuallyAdded

@Test
public void testLoadRegionFromMetaAfterRegionManuallyAdded()
                                                    throws Exception

Throws:

Exception

testLoadRegionFromMetaRegionNotInMeta

@Test
public void testLoadRegionFromMetaRegionNotInMeta()
                                           throws Exception

Throws:

Exception