org.apache.hadoop.hbase.client

Class TestHCM

java.lang.Object

org.apache.hadoop.hbase.client.TestHCM

public class TestHCM
extends Object

This class is for testing HBaseConnectionManager features

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestHCM.BlockingFilter
static class	TestHCM.SleepAndFailFirstTime This copro sleeps 20 second.

Field Summary

Fields

Modifier and Type	Field and Description
protected static AtomicBoolean	syncBlockingFilter

Constructor Summary

Constructors

Constructor and Description
TestHCM()

Method Summary

Modifier and Type	Method and Description
void	abortingHConnectionRemovesItselfFromHCM()
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testAdminFactory() Naive test to check that HConnection#getAdmin returns a properly constructed HBaseAdmin object
void	testCacheSeqNums() Test that stale cache updates don't override newer cached values.
void	testClosing()
void	testClusterConnection()
void	testClusterStatus()
void	testConnection() This test checks that one can connect to the cluster with only the ZooKeeper quorum set.
void	testConnectionCloseAllowsInterrupt() Test that we can handle connection close: it will trigger a retry, but the calls will finish.
void	testConnectionCut() Test that the connection to the dead server is cut immediately when we receive the notification.
void	testConnectionIdle() Test that connection can become idle without breaking everything.
void	testConnectionManagement() Test that Connection or Pool are not closed when managed externally
void	testConnectionNotAllowsInterrupt()
void	testConnectionRideOverClusterRestart()
void	testConnectionSameness() Make sure that Configuration instances that are essentially the same map to the same HConnection instance.
void	testConnectionUniqueness() Deprecated. Tests deprecated functionality. Remove in 1.0.
void	testCreateConnection() Trivial test to verify that nobody messes with HConnectionManager.createConnection(Configuration)
void	testDeleteForZKConnLeak() Tests that a destroyed connection does not have a live zookeeper.
void	testErrorBackoffTimeCalculation()
void	testMulti()
void	testOperationTimeout() Test that an operation can fail if we read the global operation timeout, even if the individual timeout is fine.
void	testRegionCaching() Test that when we delete a location using the first row of a region that we really delete it.

Methods inherited from class java.lang.Object

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

Field Detail

syncBlockingFilter

protected static final AtomicBoolean syncBlockingFilter

Constructor Detail

TestHCM

public TestHCM()

Method Detail

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

testClusterConnection

public void testClusterConnection()
                           throws IOException

Throws:

IOException

testAdminFactory

public void testAdminFactory()
                      throws IOException

Naive test to check that HConnection#getAdmin returns a properly constructed HBaseAdmin object

Throws:

IOException - Unable to construct admin

testClusterStatus

public void testClusterStatus()
                       throws Exception

Throws:

Exception

testConnectionCloseAllowsInterrupt

public void testConnectionCloseAllowsInterrupt()
                                        throws Exception

Test that we can handle connection close: it will trigger a retry, but the calls will finish.

Throws:

Exception

testConnectionNotAllowsInterrupt

public void testConnectionNotAllowsInterrupt()
                                      throws Exception

Throws:

Exception

testOperationTimeout

public void testOperationTimeout()
                          throws Exception

Test that an operation can fail if we read the global operation timeout, even if the individual timeout is fine. We do that with: - client side: an operation timeout of 30 seconds - server side: we sleep 20 second at each attempt. The first work fails, the second one succeeds. But the client won't wait that much, because 20 + 20 > 30, so the client timeouted when the server answers.

Throws:

Exception

testConnectionIdle

public void testConnectionIdle()
                        throws Exception

Test that connection can become idle without breaking everything.

Throws:

Exception

testConnectionCut

public void testConnectionCut()
                       throws Exception

Test that the connection to the dead server is cut immediately when we receive the notification.

Throws:

Exception

abortingHConnectionRemovesItselfFromHCM

public void abortingHConnectionRemovesItselfFromHCM()
                                             throws Exception

Throws:

Exception

testRegionCaching

public void testRegionCaching()
                       throws Exception

Test that when we delete a location using the first row of a region that we really delete it.

Throws:

Exception

testConnectionManagement

public void testConnectionManagement()
                              throws Exception

Test that Connection or Pool are not closed when managed externally

Throws:

Exception

testCacheSeqNums

public void testCacheSeqNums()
                      throws Exception

Test that stale cache updates don't override newer cached values.

Throws:

Exception

testConnectionSameness

public void testConnectionSameness()
                            throws Exception

Make sure that Configuration instances that are essentially the same map to the same HConnection instance.

Throws:

Exception

testConnectionUniqueness

@Deprecated
public void testConnectionUniqueness()
                                          throws Exception

Deprecated. Tests deprecated functionality. Remove in 1.0.

Makes sure that there is no leaking of ConnectionManager.HConnectionImplementation in the HConnectionManager class.

Throws:

Exception

testClosing

public void testClosing()
                 throws Exception

Throws:

Exception

testCreateConnection

public void testCreateConnection()
                          throws Exception

Trivial test to verify that nobody messes with HConnectionManager.createConnection(Configuration)

Throws:

Exception

testConnection

public void testConnection()
                    throws Exception

This test checks that one can connect to the cluster with only the ZooKeeper quorum set. Other stuff like master address will be read from ZK by the client.

Throws:

Exception

testMulti

public void testMulti()
               throws Exception

Throws:

Exception

testErrorBackoffTimeCalculation

public void testErrorBackoffTimeCalculation()
                                     throws Exception

Throws:

Exception

testDeleteForZKConnLeak

public void testDeleteForZKConnLeak()
                             throws Exception

Tests that a destroyed connection does not have a live zookeeper. Below is timing based. We put up a connection to a table and then close the connection while having a background thread running that is forcing close of the connection to try and provoke a close catastrophe; we are hoping for a car crash so we can see if we are leaking zk connections.

Throws:

Exception

testConnectionRideOverClusterRestart

public void testConnectionRideOverClusterRestart()
                                          throws IOException,
                                                 InterruptedException

Throws:

IOException

InterruptedException