org.apache.hadoop.hbase.replication

Class TestReplicationEmptyWALRecovery

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBase

org.apache.hadoop.hbase.replication.TestReplicationEmptyWALRecovery

public class TestReplicationEmptyWALRecovery
extends TestReplicationBase

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.replication.TestReplicationBase

TestReplicationBase.ReplicationEndpointTest

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
(package private) static org.apache.hadoop.hbase.client.RegionInfo	info
(package private) org.apache.hadoop.hbase.regionserver.MultiVersionConcurrencyControl	mvcc
(package private) NavigableMap<byte[],Integer>	scopes

Fields inherited from class org.apache.hadoop.hbase.replication.TestReplicationBase

admin, CONF_WITH_LOCALFS, CONF1, CONF2, connection1, connection2, famName, hbaseAdmin, htable1, htable2, NB_RETRIES, NB_ROWS_IN_BATCH, NB_ROWS_IN_BIG_BATCH, noRepfamName, NUM_SLAVES1, NUM_SLAVES2, PEER_ID2, replicateCount, replicatedEntries, row, SLEEP_TIME, tableName, UTIL1, UTIL2

Constructor Summary

Constructors

Constructor and Description
TestReplicationEmptyWALRecovery()

Method Summary

Modifier and Type	Method and Description
private void	appendEntriesToWal(int numEntries, org.apache.hadoop.hbase.wal.WAL wal)
protected org.apache.hadoop.hbase.wal.WALKeyImpl	getWalKeyImpl()
private void	injectEmptyWAL(int numRs, List<org.apache.hadoop.fs.Path> emptyWalPaths)
private void	rollWalsAndWaitForDeque(int numRs)
void	setUp()
void	testEmptyWALRecovery()
void	testReplicationOfEmptyWALFollowedByNonEmptyWAL() Test empty WAL along with non empty WALs in the same batch.
void	testReplicationOfEmptyWALFollowingNonEmptyWAL() Test empty WAL along with non empty WALs in the same batch.
void	testReplicationOfEmptyWALSurroundedNonEmptyWAL() This test make sure we replicate all the enties from the non empty WALs which are surrounding the empty WALs
private void	verifyNumberOfLogsInQueue(int numQueues, int numRs)
private void	waitForLogAdvance(int numRs) Waits until there is only one log(the current writing one) in the replication queue

Methods inherited from class org.apache.hadoop.hbase.replication.TestReplicationBase

addPeer, cleanUp, configureClusters, createTable, isSerialPeer, loadData, loadData, removePeer, restartSourceCluster, restartTargetHBaseCluster, runSimplePutDeleteTest, runSmallBatchTest, setUpBase, setUpBeforeClass, setupConfig, tearDownAfterClass, tearDownBase, waitForReplication, waitForReplication

Methods inherited from class java.lang.Object

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

Field Detail

mvcc

org.apache.hadoop.hbase.regionserver.MultiVersionConcurrencyControl mvcc

info

static final org.apache.hadoop.hbase.client.RegionInfo info

scopes

NavigableMap<byte[],Integer> scopes

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

Constructor Detail

TestReplicationEmptyWALRecovery

public TestReplicationEmptyWALRecovery()

Method Detail

setUp

public void setUp()
           throws IOException,
                  InterruptedException

Throws:

IOException

InterruptedException

waitForLogAdvance

private void waitForLogAdvance(int numRs)

Waits until there is only one log(the current writing one) in the replication queue

Parameters:

numRs - number of region servers

verifyNumberOfLogsInQueue

private void verifyNumberOfLogsInQueue(int numQueues,
                                       int numRs)

testEmptyWALRecovery

public void testEmptyWALRecovery()
                          throws Exception

Throws:

Exception

testReplicationOfEmptyWALFollowingNonEmptyWAL

public void testReplicationOfEmptyWALFollowingNonEmptyWAL()
                                                   throws Exception

Test empty WAL along with non empty WALs in the same batch. This test is to make sure when we see the empty and handle the EOF exception, we are able to ship the previous batch of entries without loosing it. This test also tests the number of batches shipped

Throws:

Exception - throws any exception

testReplicationOfEmptyWALFollowedByNonEmptyWAL

public void testReplicationOfEmptyWALFollowedByNonEmptyWAL()
                                                    throws Exception

Test empty WAL along with non empty WALs in the same batch. This test is to make sure when we see the empty WAL and handle the EOF exception, we are able to proceed with next batch and replicate it properly without missing data.

Throws:

Exception - throws any exception

testReplicationOfEmptyWALSurroundedNonEmptyWAL

public void testReplicationOfEmptyWALSurroundedNonEmptyWAL()
                                                    throws Exception

This test make sure we replicate all the enties from the non empty WALs which are surrounding the empty WALs

Throws:

Exception - throws exception

injectEmptyWAL

private void injectEmptyWAL(int numRs,
                            List<org.apache.hadoop.fs.Path> emptyWalPaths)
                     throws IOException

Throws:

IOException

getWalKeyImpl

protected org.apache.hadoop.hbase.wal.WALKeyImpl getWalKeyImpl()

rollWalsAndWaitForDeque

private void rollWalsAndWaitForDeque(int numRs)
                              throws IOException

Throws:

IOException

appendEntriesToWal

private void appendEntriesToWal(int numEntries,
                                org.apache.hadoop.hbase.wal.WAL wal)
                         throws IOException

Throws:

IOException