Package org.apache.hadoop.hbase.mapred

Class TestTableOutputFormatConnectionExhaust

java.lang.Object

org.apache.hadoop.hbase.mapred.TestTableOutputFormatConnectionExhaust

public class TestTableOutputFormatConnectionExhaust
extends Object

Spark creates many instances of TableOutputFormat within a single process. We need to make sure we can have many instances and not leak connections. This test creates a few TableOutputFormats and shouldn't fail due to ZK connection exhaustion.

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
(package private) static final String	FAMILY
private static final org.slf4j.Logger	LOG
(package private) static final String	TABLE
private static final HBaseTestingUtil	UTIL

Constructor Summary

Constructors

Constructor	Description
TestTableOutputFormatConnectionExhaust()

Method Summary

Modifier and Type	Method	Description
static void	afterClass()
void	before()
static void	beforeClass()
(package private) static void	openCloseTableOutputFormat(int iter)	Open and close a TableOutputFormat.
void	testConnectionExhaustion()

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

UTIL

private static final HBaseTestingUtil UTIL

TABLE

static final String TABLE

See Also:

• Constant Field Values

FAMILY

static final String FAMILY

See Also:

• Constant Field Values

Constructor Details

TestTableOutputFormatConnectionExhaust

public TestTableOutputFormatConnectionExhaust()

Method Details

beforeClass

public static void beforeClass()
                        throws Exception

Throws:

Exception

afterClass

public static void afterClass()
                       throws Exception

Throws:

Exception

before

public void before()
            throws IOException

Throws:

IOException

openCloseTableOutputFormat

static void openCloseTableOutputFormat(int iter)
                                throws IOException

Open and close a TableOutputFormat. The closing the RecordWriter should release HBase Connection (ZK) resources, and will throw exception if they are exhausted.

Throws:

IOException

testConnectionExhaustion

public void testConnectionExhaustion()
                              throws IOException

Throws:

IOException