Package org.apache.hadoop.hbase.client

Class FromClientSideScanExcpetionTestBase

java.lang.Object

org.apache.hadoop.hbase.client.FromClientSideScanExcpetionTestBase

Direct Known Subclasses:

TestFromClientSideScanExcpetion, TestFromClientSideScanExcpetionWithCoprocessor

public class FromClientSideScanExcpetionTestBase
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	FromClientSideScanExcpetionTestBase.MyHRegion
static final class	FromClientSideScanExcpetionTestBase.MyHStore
static final class	FromClientSideScanExcpetionTestBase.MyStoreScanner

Field Summary

Fields

Modifier and Type	Field	Description
protected static byte[]	FAMILY
private static AtomicBoolean	IS_DO_NOT_RETRY
private TableNameTestExtension	name
private static AtomicBoolean	ON
private static AtomicLong	REQ_COUNT
protected static int	SLAVES
protected static final HBaseTestingUtil	TEST_UTIL
private static AtomicBoolean	THROW_ONCE

Constructor Summary

Constructors

Constructor	Description
FromClientSideScanExcpetionTestBase()

Method Summary

Modifier and Type	Method	Description
private static void	inject()
private static void	reset()
protected static void	startCluster()
static void	tearDownAfterClass()
void	testClientScannerIsResetWhenScanThrowsIOException()	Tests the case where a Scan can throw an IOException in the middle of the seek / reseek leaving the server side RegionScanner to be in dirty state.
void	testScannerFailsAfterRetriesWhenCoprocessorThrowsIOE()	Tests the case where a coprocessor throws a regular IOException in the scan.
void	testScannerThrowsExceptionWhenCoprocessorThrowsDNRIOE()	Tests the case where a coprocessor throws a DoNotRetryIOException in the scan.

Methods inherited from class java.lang.Object

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

Field Details

TEST_UTIL

protected static final HBaseTestingUtil TEST_UTIL

FAMILY

protected static byte[] FAMILY

SLAVES

protected static int SLAVES

name

@RegisterExtension
private TableNameTestExtension name

ON

private static AtomicBoolean ON

REQ_COUNT

private static AtomicLong REQ_COUNT

IS_DO_NOT_RETRY

private static AtomicBoolean IS_DO_NOT_RETRY

THROW_ONCE

private static AtomicBoolean THROW_ONCE

Constructor Details

FromClientSideScanExcpetionTestBase

public FromClientSideScanExcpetionTestBase()

Method Details

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

reset

private static void reset()

inject

private static void inject()

startCluster

protected static void startCluster()
                            throws Exception

Throws:

Exception

testClientScannerIsResetWhenScanThrowsIOException

@Test
public void testClientScannerIsResetWhenScanThrowsIOException()
                                                       throws IOException,
InterruptedException

Tests the case where a Scan can throw an IOException in the middle of the seek / reseek leaving the server side RegionScanner to be in dirty state. The client has to ensure that the ClientScanner does not get an exception and also sees all the data.

Throws:

IOException

InterruptedException

testScannerThrowsExceptionWhenCoprocessorThrowsDNRIOE

@Test
public void testScannerThrowsExceptionWhenCoprocessorThrowsDNRIOE()
                                                           throws IOException,
InterruptedException

Tests the case where a coprocessor throws a DoNotRetryIOException in the scan. The expectation is that the exception will bubble up to the client scanner instead of being retried.

Throws:

IOException

InterruptedException

testScannerFailsAfterRetriesWhenCoprocessorThrowsIOE

@Test
public void testScannerFailsAfterRetriesWhenCoprocessorThrowsIOE()
                                                          throws IOException,
InterruptedException

Tests the case where a coprocessor throws a regular IOException in the scan. The expectation is that the we will keep on retrying, but fail after the retries are exhausted instead of retrying indefinitely.

Throws:

IOException

InterruptedException