public class TestAMServerFailedOpen extends 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| Modifier and Type | Field and Description |
|---|---|
static HBaseClassTestRule |
CLASS_RULE |
private static org.slf4j.Logger |
LOG |
am, assignFailedCount, assignProcMetrics, assignSubmittedCount, closeFailedCount, closeProcMetrics, closeSubmittedCount, exception, executor, master, moveFailedCount, moveProcMetrics, moveSubmittedCount, name, newRsAdded, NREGIONS, NSERVERS, openFailedCount, openProcMetrics, openSubmittedCount, PROC_NTHREADS, regionsToRegionServers, reopenFailedCount, reopenProcMetrics, reopenSubmittedCount, rsDispatcher, unassignFailedCount, unassignProcMetrics, unassignSubmittedCount, util| Constructor and Description |
|---|
TestAMServerFailedOpen() |
| Modifier and Type | Method and Description |
|---|---|
protected int |
getAssignMaxAttempts() |
void |
testCallQueueTooBigExceptionOnAssignment() |
void |
testDoNotRetryExceptionOnAssignment() |
private void |
testFailedOpen(org.apache.hadoop.hbase.TableName tableName,
TestAssignmentManagerBase.MockRSExecutor executor) |
private void |
testRetriesExhaustedFailure(org.apache.hadoop.hbase.TableName tableName,
TestAssignmentManagerBase.MockRSExecutor executor) |
void |
testServerNotYetRunning() |
bulkSubmit, collectAssignmentManagerMetrics, createAndSubmitAssign, createAssignProcedure, createRegionInfo, createUnassignProcedure, doCrash, doRestart, sendTransitionReport, setUp, setupConfiguration, setUpMeta, submitProcedure, tearDown, waitOnFuturepublic static final HBaseClassTestRule CLASS_RULE
private static final org.slf4j.Logger LOG
public TestAMServerFailedOpen()
protected int getAssignMaxAttempts()
getAssignMaxAttempts in class TestAssignmentManagerBasepublic void testServerNotYetRunning() throws Exception
Exceptionprivate void testRetriesExhaustedFailure(org.apache.hadoop.hbase.TableName tableName, TestAssignmentManagerBase.MockRSExecutor executor) throws Exception
Exceptionpublic void testDoNotRetryExceptionOnAssignment() throws Exception
Exceptionprivate void testFailedOpen(org.apache.hadoop.hbase.TableName tableName, TestAssignmentManagerBase.MockRSExecutor executor) throws Exception
Exceptionpublic void testCallQueueTooBigExceptionOnAssignment() throws Exception
ExceptionCopyright © 2007–2021 The Apache Software Foundation. All rights reserved.