org.apache.hadoop.hbase.replication.regionserver

Class TestReplicationSource

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.TestReplicationSource

public class TestReplicationSource
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestReplicationSource.BadReplicationEndpoint Bad Endpoint with failing connection to peer on demand.
static class	TestReplicationSource.DoNothingReplicationEndpoint Deadend Endpoint.
static class	TestReplicationSource.FaultyReplicationEndpoint
static class	TestReplicationSource.FlakyReplicationEndpoint Deadend Endpoint.
static class	TestReplicationSource.ShutdownDelayRegionServer Regionserver implementation that adds a delay on the graceful shutdown.

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static org.apache.hadoop.conf.Configuration	conf
private static org.apache.hadoop.fs.FileSystem	FS
private static org.slf4j.Logger	LOG
private static org.apache.hadoop.fs.Path	logDir
private static org.apache.hadoop.fs.Path	oldLogDir
private static HBaseTestingUtility	TEST_UTIL
private static HBaseTestingUtility	TEST_UTIL_PEER

Constructor Summary

Constructors

Constructor and Description
TestReplicationSource()

Method Summary

Modifier and Type	Method and Description
private org.apache.hadoop.hbase.replication.regionserver.MetricsReplicationSourceSource	getSourceMetrics(String sourceId)
static void	setUpBeforeClass()
private org.apache.hadoop.hbase.regionserver.RegionServerServices	setupForAbortTests(org.apache.hadoop.hbase.replication.regionserver.ReplicationSource rs, org.apache.hadoop.conf.Configuration conf, String endpointName)
static void	tearDownAfterClass()
void	testAbortFalseOnError() Test ReplicationSource retries startup once an uncaught exception happens during initialization and eplication.source.regionserver.abort is set to false.
void	testAbortFalseOnErrorDoesntBlockMainThread() Test ReplicationSource keeps retrying startup indefinitely without blocking the main thread, when replication.source.regionserver.abort is set to false.
void	testAbortTrueOnError() Test ReplicationSource retries startup once an uncaught exception happens during initialization and replication.source.regionserver.abort is set to true.
void	testAgeOfOldestWal()
void	testDefaultSkipsMetaWAL() Test the default ReplicationSource skips queuing hbase:meta WAL files.
void	testLogMoving() Sanity check that we can move logs around while we are reading from them.
void	testRecoveredReplicationSourceShipperGetPosition() Test HBASE-20497 Moved here from TestReplicationSource because doesn't need cluster.
void	testReplicationSourceInitializingMetric()
void	testServerShutdownRecoveredQueue() Tests that recovered queues are preserved on a regionserver shutdown.
void	testTerminateClearsBuffer()
void	testTerminateTimeout() Tests that ReplicationSource.terminate(String) will timeout properly Moved here from TestReplicationSource because doesn't need cluster.
void	testWALEntryFilter() Test that we filter out meta edits, etc.

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

LOG

private static final org.slf4j.Logger LOG

TEST_UTIL

private static final HBaseTestingUtility TEST_UTIL

TEST_UTIL_PEER

private static final HBaseTestingUtility TEST_UTIL_PEER

FS

private static org.apache.hadoop.fs.FileSystem FS

oldLogDir

private static org.apache.hadoop.fs.Path oldLogDir

logDir

private static org.apache.hadoop.fs.Path logDir

conf

private static org.apache.hadoop.conf.Configuration conf

Constructor Detail

TestReplicationSource

public TestReplicationSource()

Method Detail

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

testDefaultSkipsMetaWAL

public void testDefaultSkipsMetaWAL()
                             throws IOException

Test the default ReplicationSource skips queuing hbase:meta WAL files.

Throws:

IOException

testWALEntryFilter

public void testWALEntryFilter()
                        throws IOException

Test that we filter out meta edits, etc.

Throws:

IOException

testLogMoving

public void testLogMoving()
                   throws Exception

Sanity check that we can move logs around while we are reading from them. Should this test fail, ReplicationSource would have a hard time reading logs that are being archived.

Throws:

Exception

testTerminateTimeout

public void testTerminateTimeout()
                          throws Exception

Tests that ReplicationSource.terminate(String) will timeout properly Moved here from TestReplicationSource because doesn't need cluster.

Throws:

Exception

testTerminateClearsBuffer

public void testTerminateClearsBuffer()
                               throws Exception

Throws:

Exception

testServerShutdownRecoveredQueue

public void testServerShutdownRecoveredQueue()
                                      throws Exception

Tests that recovered queues are preserved on a regionserver shutdown. See HBASE-18192

Throws:

Exception

testRecoveredReplicationSourceShipperGetPosition

public void testRecoveredReplicationSourceShipperGetPosition()
                                                      throws Exception

Test HBASE-20497 Moved here from TestReplicationSource because doesn't need cluster.

Throws:

Exception

setupForAbortTests

private org.apache.hadoop.hbase.regionserver.RegionServerServices setupForAbortTests(org.apache.hadoop.hbase.replication.regionserver.ReplicationSource rs,
                                                                                     org.apache.hadoop.conf.Configuration conf,
                                                                                     String endpointName)
                                                                              throws IOException

Throws:

IOException

testAbortFalseOnError

public void testAbortFalseOnError()
                           throws IOException

Test ReplicationSource retries startup once an uncaught exception happens during initialization and eplication.source.regionserver.abort is set to false.

Throws:

IOException

testReplicationSourceInitializingMetric

public void testReplicationSourceInitializingMetric()
                                             throws IOException

Throws:

IOException

testAbortFalseOnErrorDoesntBlockMainThread

public void testAbortFalseOnErrorDoesntBlockMainThread()
                                                throws IOException

Test ReplicationSource keeps retrying startup indefinitely without blocking the main thread, when replication.source.regionserver.abort is set to false.

Throws:

IOException

testAbortTrueOnError

public void testAbortTrueOnError()
                          throws IOException

Test ReplicationSource retries startup once an uncaught exception happens during initialization and replication.source.regionserver.abort is set to true.

Throws:

IOException

testAgeOfOldestWal

public void testAgeOfOldestWal()
                        throws Exception

Throws:

Exception

getSourceMetrics

private org.apache.hadoop.hbase.replication.regionserver.MetricsReplicationSourceSource getSourceMetrics(String sourceId)