Package org.apache.hadoop.hbase.regionserver

Class TestScannerTimeoutHandling

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestScannerTimeoutHandling

public class TestScannerTimeoutHandling
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	TestScannerTimeoutHandling.RegionServerWithScanTimeout
private static class	TestScannerTimeoutHandling.RSRpcServicesWithScanTimeout

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static org.apache.hadoop.hbase.client.Connection	CONN
private static final org.slf4j.Logger	LOG
private static final MetricsAssertHelper	METRICS_ASSERT
org.junit.rules.TestName	name
private static final org.apache.hadoop.hbase.TableName	TABLE_NAME
private static final HBaseTestingUtility	TEST_UTIL
private static final int	TIMEOUT

Constructor Summary

Constructors

Constructor	Description
TestScannerTimeoutHandling()

Method Summary

Modifier and Type	Method	Description
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testExceededClientDeadline()	If a client's timeout would be exceeded before scan results are ready, there is no point returning results to the client.

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

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

TEST_UTIL

private static final HBaseTestingUtility TEST_UTIL

METRICS_ASSERT

private static final MetricsAssertHelper METRICS_ASSERT

TIMEOUT

private static final int TIMEOUT

See Also:

• Constant Field Values

TABLE_NAME

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

CONN

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

name

public org.junit.rules.TestName name

Constructor Details

TestScannerTimeoutHandling

public TestScannerTimeoutHandling()

Method Details

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

testExceededClientDeadline

public void testExceededClientDeadline()
                                throws Exception

If a client's timeout would be exceeded before scan results are ready, there is no point returning results to the client. Worse, for openScanner calls, the client cannot close the timed out scanner so this leaks scanners on the server. This test verifies that we properly track and cleanup scanners when a client timeout is exceeded. This should be more rare when heartbeats are enabled, since we try to return before timeout there. But it's still possible if queueing eats up most of the timeout or the inner workings of the scan were slowed down enough to still exceed the timeout despite the calculated heartbeat deadline.

Throws:

Exception