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 int	DELAY_GET
private static int	DELAY_MUTATE
private static int	DELAY_SCAN
private byte[]	FAMILY
org.junit.rules.TestName	name
private byte[]	QUALIFIER
private byte[]	ROW
private org.apache.hadoop.hbase.client.Table	table
private static HBaseTestingUtility	TESTING_UTIL
private 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

TESTING_UTIL

private static final HBaseTestingUtility TESTING_UTIL

DELAY_GET

private static int DELAY_GET

DELAY_SCAN

private static int DELAY_SCAN

DELAY_MUTATE

private static int DELAY_MUTATE

FAMILY

private final byte[] FAMILY

ROW

private final byte[] ROW

QUALIFIER

private final byte[] QUALIFIER

VALUE

private final byte[] VALUE

name

public org.junit.rules.TestName name

table

private 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