org.apache.hadoop.hbase.master.assignment

Class TestUnexpectedStateException

java.lang.Object

org.apache.hadoop.hbase.master.assignment.TestUnexpectedStateException

public class TestUnexpectedStateException
extends Object

Tests for HBASE-18408 "AM consumes CPU and fills up the logs really fast when there is no RS to assign". If an UnexpectedStateException, we'd spin on the ProcedureExecutor consuming CPU and filling logs. Test new back-off facility.

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static byte[]	FAMILY
private static org.slf4j.Logger	LOG
org.junit.rules.TestName	name
private static int	REGIONS
private org.apache.hadoop.hbase.TableName	tableName
private static HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor and Description
TestUnexpectedStateException()

Method Summary

Modifier and Type	Method and Description
static void	afterClass()
void	before()
static void	beforeClass()
private long	getUnassignTimeout(org.apache.hbase.thirdparty.com.google.gson.JsonParser parser, String proceduresAsJSON)
private org.apache.hadoop.hbase.client.RegionInfo	pickArbitraryRegion(org.apache.hadoop.hbase.client.Admin admin)
void	testUnableToAssign() Manufacture a state that will throw UnexpectedStateException.

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

name

public final org.junit.rules.TestName name

LOG

private static final org.slf4j.Logger LOG

TEST_UTIL

private static final HBaseTestingUtility TEST_UTIL

FAMILY

private static final byte[] FAMILY

tableName

private org.apache.hadoop.hbase.TableName tableName

REGIONS

private static final int REGIONS

See Also:

Constant Field Values

Constructor Detail

TestUnexpectedStateException

public TestUnexpectedStateException()

Method Detail

beforeClass

public static void beforeClass()
                        throws Exception

Throws:

Exception

afterClass

public static void afterClass()
                       throws Exception

Throws:

Exception

before

public void before()
            throws IOException

Throws:

IOException

pickArbitraryRegion

private org.apache.hadoop.hbase.client.RegionInfo pickArbitraryRegion(org.apache.hadoop.hbase.client.Admin admin)
                                                               throws IOException

Throws:

IOException

testUnableToAssign

public void testUnableToAssign()
                        throws Exception

Manufacture a state that will throw UnexpectedStateException. Change an assigned region's 'state' to be OPENING. That'll mess up a subsequent unassign causing it to throw UnexpectedStateException. We can easily manufacture this infinite retry state in UnassignProcedure because it has no startTransition. AssignProcedure does where it squashes whatever the current region state is making it OFFLINE. That makes it harder to mess it up. Make do with UnassignProcedure for now.

Throws:

Exception

getUnassignTimeout

private long getUnassignTimeout(org.apache.hbase.thirdparty.com.google.gson.JsonParser parser,
                                String proceduresAsJSON)
                         throws Exception

Parameters:

proceduresAsJSON - This is String returned by admin.getProcedures call... an array of Procedures as JSON.

Returns:

The Procedure timeout value parsed from the Unassign Procedure.

Throws:

Exception