Package org.apache.hadoop.hbase.client

Class TestMalformedCellFromClient

java.lang.Object

org.apache.hadoop.hbase.client.TestMalformedCellFromClient

@Tag("org.apache.hadoop.hbase.testclassification.MediumTests") @Tag("org.apache.hadoop.hbase.testclassification.ClientTests")
public class TestMalformedCellFromClient
extends Object

The purpose of this test is to ensure whether rs deals with the malformed cells correctly.

Field Summary

Fields

Modifier and Type	Field	Description
private static final int	CELL_SIZE
private static final byte[]	FAMILY
private static final org.slf4j.Logger	LOG
private static final org.apache.hadoop.hbase.TableName	TABLE_NAME
private static final HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestMalformedCellFromClient()

Method Summary

Modifier and Type	Method	Description
private static void	assertObjects(Object[] objs, int expectedSize)
void	before()
private static org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiRequest	createRequest(org.apache.hadoop.hbase.client.RowMutations rm, byte[] regionName)
static void	setUpBeforeClass()
void	tearDown()
static void	tearDownAfterClass()
void	testAtomicOperations()	The invalid cells is in rm.
void	testNonAtomicOperations()	This test depends on how regionserver process the batch ops.
void	testRegionException()	The purpose of this ut is to check the consistency between the exception and results.
void	testRegionExceptionByAsync()	This test verifies region exception doesn't corrupt the results of batch.
void	testRowMutations()

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

FAMILY

private static final byte[] FAMILY

CELL_SIZE

private static final int CELL_SIZE

See Also:

• Constant Field Values

TABLE_NAME

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

Constructor Details

TestMalformedCellFromClient

public TestMalformedCellFromClient()

Method Details

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

before

@BeforeEach
public void before()
            throws Exception

Throws:

Exception

tearDown

@AfterEach
public void tearDown()
              throws Exception

Throws:

Exception

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

testRegionException

@Test
public void testRegionException()
                         throws InterruptedException,
IOException

The purpose of this ut is to check the consistency between the exception and results. If the RetriesExhaustedWithDetailsException contains the whole batch, each result should be of IOE. Otherwise, the row operation which is not in the exception should have a true result.

Throws:

InterruptedException

IOException

testRegionExceptionByAsync

@Test
public void testRegionExceptionByAsync()
                                throws Exception

This test verifies region exception doesn'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. If the RetriesExhaustedWithDetailsException contains the whole batch, each result should be of IOE. Otherwise, the row operation which is not in the exception should have a true result. The no-cluster test is in TestAsyncProcessWithRegionException.

Throws:

Exception

testAtomicOperations

@Test
public void testAtomicOperations()
                          throws Exception

The invalid cells is in rm. The rm should fail but the subsequent mutations should succeed. Currently, we have no client api to submit the request consisting of condition-rm and mutation. Hence, this test build the request manually.

Throws:

Exception

createRequest

private static org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiRequest createRequest(org.apache.hadoop.hbase.client.RowMutations rm,
 byte[] regionName)
                                                                                                  throws IOException

Throws:

IOException

testNonAtomicOperations

@Test
public void testNonAtomicOperations()
                             throws InterruptedException,
IOException

This test depends on how regionserver process the batch ops. 1) group the put/delete until meeting the increment 2) process the batch of put/delete 3) process the increment see RSRpcServices#doNonAtomicRegionMutation

Throws:

InterruptedException

IOException

testRowMutations

@Test
public void testRowMutations()
                      throws InterruptedException,
IOException

Throws:

InterruptedException

IOException

assertObjects

private static void assertObjects(Object[] objs,
 int expectedSize)