public class TestAssignmentManager extends TestAssignmentManagerBase
TestAssignmentManagerBase.FaultyRsExecutor, TestAssignmentManagerBase.GoodRsExecutor, TestAssignmentManagerBase.HangOnCloseThenRSCrashExecutor, TestAssignmentManagerBase.HangThenRSCrashExecutor, TestAssignmentManagerBase.HangThenRSRestartExecutor, TestAssignmentManagerBase.MockRSExecutor, TestAssignmentManagerBase.MockRSProcedureDispatcher, TestAssignmentManagerBase.NoopRsExecutor, TestAssignmentManagerBase.RandRsExecutor, TestAssignmentManagerBase.ServerNotYetRunningRsExecutor, TestAssignmentManagerBase.SocketTimeoutRsExecutor
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
private static org.slf4j.Logger |
LOG |
am, assignFailedCount, assignProcMetrics, assignSubmittedCount, exception, executor, master, name, NREGIONS, NSERVERS, regionsToRegionServers, rsDispatcher, unassignFailedCount, unassignProcMetrics, unassignSubmittedCount, UTIL
Constructor and Description |
---|
TestAssignmentManager() |
bulkSubmit, collectAssignmentManagerMetrics, createRegionInfo, setUp, setupConfiguration, submitProcedure, tearDown, waitOnFuture
private static final org.slf4j.Logger LOG
public static final HBaseClassTestRule CLASS_RULE
public TestAssignmentManager()
public void testWaitServerReportEventWithNullServer() throws org.apache.hadoop.hbase.exceptions.UnexpectedStateException
org.apache.hadoop.hbase.exceptions.UnexpectedStateException
public void testAssignWithGoodExec() throws Exception
Exception
public void testAssignAndCrashBeforeResponse() throws Exception
Exception
public void testUnassignAndCrashBeforeResponse() throws Exception
Exception
public void testAssignWithRandExec() throws Exception
Exception
public void testSocketTimeout() throws Exception
Exception
public void testServerNotYetRunning() throws Exception
Exception
private void testRetriesExhaustedFailure(org.apache.hadoop.hbase.TableName tableName, TestAssignmentManagerBase.MockRSExecutor executor) throws Exception
Exception
public void testIOExceptionOnAssignment() throws Exception
Exception
public void testDoNotRetryExceptionOnAssignment() throws Exception
Exception
private void testFailedOpen(org.apache.hadoop.hbase.TableName tableName, TestAssignmentManagerBase.MockRSExecutor executor) throws Exception
Exception
private void testAssign(TestAssignmentManagerBase.MockRSExecutor executor) throws Exception
Exception
private void testAssign(TestAssignmentManagerBase.MockRSExecutor executor, int nregions) throws Exception
Exception
public void testAssignAnAssignedRegion() throws Exception
Exception
public void testUnassignAnUnassignedRegion() throws Exception
Exception
public void testAssignMetaAndCrashBeforeResponse() throws Exception
Exception
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.