org.apache.hadoop.hbase

Class TestClientOperationTimeout

java.lang.Object

org.apache.hadoop.hbase.TestClientOperationTimeout

public class TestClientOperationTimeout
extends Object

These tests verify that the RPC timeouts ('hbase.client.operation.timeout' and 'hbase.client.scanner.timeout.period') work correctly using a modified Region Server which injects delays to get, scan and mutate operations.

When 'hbase.client.operation.timeout' is set and client operation is not completed in time the client will retry the operation 'hbase.client.retries.number' times. After that SocketTimeoutException will be thrown.

Using 'hbase.client.scanner.timeout.period' configuration property similar behavior can be specified for scan related operations such as openScanner(), next(). If that times out RetriesExhaustedException will be thrown.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	TestClientOperationTimeout.DelayedRegionServer
static class	TestClientOperationTimeout.DelayedRSRpcServices This RSRpcServices class injects delay for Rpc calls and after executes super methods.

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static org.apache.hadoop.hbase.client.Connection	CONN
private static int	DELAY_GET
private static int	DELAY_MUTATE
private static int	DELAY_SCAN
private static byte[]	FAMILY
private static byte[]	QUALIFIER
private static byte[]	ROW
private static org.apache.hadoop.hbase.client.Table	TABLE
private static org.apache.hadoop.hbase.TableName	TABLE_NAME
private static HBaseTestingUtility	UTIL
private static byte[]	VALUE

Constructor Summary

Constructors

Constructor and Description
TestClientOperationTimeout()

Method Summary

Modifier and Type	Method and Description
void	setUp()
static void	setUpClass()
static void	tearDown()
void	testGetTimeout() Tests that a get on a table throws SocketTimeoutException when the operation takes longer than 'hbase.client.operation.timeout'.
void	testPutTimeout() Tests that a put on a table throws SocketTimeoutException when the operation takes longer than 'hbase.client.operation.timeout'.
void	testScanTimeout() Tests that scan on a table throws RetriesExhaustedException when the operation takes longer than 'hbase.client.scanner.timeout.period'.

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

UTIL

private static final HBaseTestingUtility UTIL

DELAY_GET

private static int DELAY_GET

DELAY_SCAN

private static int DELAY_SCAN

DELAY_MUTATE

private static int DELAY_MUTATE

TABLE_NAME

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

FAMILY

private static final byte[] FAMILY

ROW

private static final byte[] ROW

QUALIFIER

private static final byte[] QUALIFIER

VALUE

private static final byte[] VALUE

CONN

private static org.apache.hadoop.hbase.client.Connection CONN

TABLE

private static org.apache.hadoop.hbase.client.Table TABLE

Constructor Detail

TestClientOperationTimeout

public TestClientOperationTimeout()

Method Detail

setUpClass

public static void setUpClass()
                       throws Exception

Throws:

Exception

setUp

public void setUp()
           throws Exception

Throws:

Exception

tearDown

public static void tearDown()
                     throws Exception

Throws:

Exception

testGetTimeout

public void testGetTimeout()
                    throws Exception

Tests that a get on a table throws SocketTimeoutException when the operation takes longer than 'hbase.client.operation.timeout'.

Throws:

Exception

testPutTimeout

public void testPutTimeout()
                    throws Exception

Tests that a put on a table throws SocketTimeoutException when the operation takes longer than 'hbase.client.operation.timeout'.

Throws:

Exception

testScanTimeout

public void testScanTimeout()
                     throws Exception

Tests that scan on a table throws RetriesExhaustedException when the operation takes longer than 'hbase.client.scanner.timeout.period'.

Throws:

Exception