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

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
static final HBaseClassTestRule	CLASS_RULE
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, name, newRsAdded, NREGIONS, NSERVERS, openFailedCount, openProcMetrics, openSubmittedCount, PROC_NTHREADS, regionsToRegionServers, reopenFailedCount, reopenProcMetrics, reopenSubmittedCount, rsDispatcher, 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, 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

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

Constructor Details

TestAssignmentManager

public TestAssignmentManager()

Method Details

testAssignWithGoodExec

public void testAssignWithGoodExec()
                            throws Exception

Throws:

Exception

testAssignAndCrashBeforeResponse

public void testAssignAndCrashBeforeResponse()
                                      throws Exception

Throws:

Exception

testUnassignAndCrashBeforeResponse

public void testUnassignAndCrashBeforeResponse()
                                        throws Exception

Throws:

Exception

testAssignSocketTimeout

public void testAssignSocketTimeout()
                             throws Exception

Throws:

Exception

testAssignQueueFullOnce

public void testAssignQueueFullOnce()
                             throws Exception

Throws:

Exception

testTimeoutThenQueueFull

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

public void testAssignAnAssignedRegion()
                                throws Exception

Throws:

Exception

testUnassignAnUnassignedRegion

public void testUnassignAnUnassignedRegion()
                                    throws Exception

Throws:

Exception

testAssignMetaAndCrashBeforeResponse

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

public void testMove()
              throws Exception

Throws:

Exception

testReopen

public void testReopen()
                throws Exception

Throws:

Exception

testLoadRegionFromMetaAfterRegionManuallyAdded

public void testLoadRegionFromMetaAfterRegionManuallyAdded()
                                                    throws Exception

Throws:

Exception

testLoadRegionFromMetaRegionNotInMeta

public void testLoadRegionFromMetaRegionNotInMeta()
                                           throws Exception

Throws:

Exception