org.apache.hadoop.hbase.client

Class TestAsyncProcessWithRegionException

java.lang.Object

org.apache.hadoop.hbase.client.TestAsyncProcessWithRegionException

public class TestAsyncProcessWithRegionException
extends Object

The purpose of this test is to make sure the region exception won't corrupt the results of batch. The prescription is shown below. 1) honor the action result rather than region exception. If the action have both of true result and region exception, the action is fine as the exception is caused by other actions which are in the same region. 2) honor the action exception rather than region exception. If the action have both of action exception and region exception, we deal with the action exception only. If we also handle the region exception for the same action, it will introduce the negative count of actions in progress. The AsyncRequestFuture#waitUntilDone will block forever. This bug can be reproduced by real use case. see TestMalformedCellFromClient(in branch-1.4+). It uses the batch of RowMutations to present the bug. Given that the batch of RowMutations is only supported by branch-1.4+, perhaps the branch-1.3 and branch-1.2 won't encounter this issue. We still backport the fix to branch-1.3 and branch-1.2 in case we ignore some write paths.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	TestAsyncProcessWithRegionException.MyAsyncProcess

Field Summary

Fields

Modifier and Type	Field and Description
private static byte[]	BAD_ROW
private static byte[]	BAD_ROW_WITHOUT_ACTION_EXCEPTION
static HBaseClassTestRule	CLASS_RULE
private static org.apache.hadoop.conf.Configuration	CONF
private static org.apache.hadoop.hbase.TableName	DUMMY_TABLE
private static org.apache.hadoop.hbase.client.Result	EMPTY_RESULT
private static byte[]	FAMILY
private static byte[]	GOOD_ROW
private static IOException	IOE
private static org.apache.hadoop.hbase.client.RegionInfo	REGION_INFO
private static org.apache.hadoop.hbase.HRegionLocation	REGION_LOCATION
private static org.apache.hadoop.hbase.ServerName	SERVER_NAME

Constructor Summary

Constructors

Constructor and Description
TestAsyncProcessWithRegionException()

Method Summary

Modifier and Type	Method and Description
private static void	assertActionsInProgress(org.apache.hadoop.hbase.client.AsyncRequestFuture arf)
private static void	assertError(org.apache.hadoop.hbase.client.AsyncRequestFuture arf, int expectedCountOfFailure)
private static org.apache.hadoop.hbase.client.ClusterConnection	createHConnection()
private static void	setMockLocation(org.apache.hadoop.hbase.client.ClusterConnection hc, byte[] row, org.apache.hadoop.hbase.RegionLocations result)
static void	setUpBeforeClass()
void	testFailedPut()
void	testFailedPutWithoutActionException()
void	testSuccessivePut()

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

EMPTY_RESULT

private static final org.apache.hadoop.hbase.client.Result EMPTY_RESULT

IOE

private static final IOException IOE

CONF

private static final org.apache.hadoop.conf.Configuration CONF

DUMMY_TABLE

private static final org.apache.hadoop.hbase.TableName DUMMY_TABLE

GOOD_ROW

private static final byte[] GOOD_ROW

BAD_ROW

private static final byte[] BAD_ROW

BAD_ROW_WITHOUT_ACTION_EXCEPTION

private static final byte[] BAD_ROW_WITHOUT_ACTION_EXCEPTION

FAMILY

private static final byte[] FAMILY

SERVER_NAME

private static final org.apache.hadoop.hbase.ServerName SERVER_NAME

REGION_INFO

private static final org.apache.hadoop.hbase.client.RegionInfo REGION_INFO

REGION_LOCATION

private static final org.apache.hadoop.hbase.HRegionLocation REGION_LOCATION

Constructor Detail

TestAsyncProcessWithRegionException

public TestAsyncProcessWithRegionException()

Method Detail

setUpBeforeClass

public static void setUpBeforeClass()

testSuccessivePut

public void testSuccessivePut()
                       throws Exception

Throws:

Exception

testFailedPut

public void testFailedPut()
                   throws Exception

Throws:

Exception

testFailedPutWithoutActionException

public void testFailedPutWithoutActionException()
                                         throws Exception

Throws:

Exception

assertError

private static void assertError(org.apache.hadoop.hbase.client.AsyncRequestFuture arf,
                                int expectedCountOfFailure)

assertActionsInProgress

private static void assertActionsInProgress(org.apache.hadoop.hbase.client.AsyncRequestFuture arf)

createHConnection

private static org.apache.hadoop.hbase.client.ClusterConnection createHConnection()
                                                                           throws IOException

Throws:

IOException

setMockLocation

private static void setMockLocation(org.apache.hadoop.hbase.client.ClusterConnection hc,
                                    byte[] row,
                                    org.apache.hadoop.hbase.RegionLocations result)
                             throws IOException

Throws:

IOException