Package org.apache.hadoop.hbase.replication

Class TestReplicationSyncUpTool

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationSyncUpToolBase

org.apache.hadoop.hbase.replication.TestReplicationSyncUpTool

Direct Known Subclasses:

TestReplicationSyncUpToolWithMultipleAsyncWAL, TestReplicationSyncUpToolWithMultipleWAL

@Tag("org.apache.hadoop.hbase.testclassification.ReplicationTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestReplicationSyncUpTool
extends TestReplicationSyncUpToolBase

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG

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

conn1, conn2, FAMILY, ht1Source, ht1TargetAtPeer1, ht2Source, ht2TargetAtPeer1, NO_REP_FAMILY, QUALIFIER, t1SyncupSource, t1SyncupTarget, t2SyncupSource, t2SyncupTarget, TN1, TN2, UTIL1, UTIL2

Constructor Summary

Constructors

Constructor	Description
TestReplicationSyncUpTool()

Method Summary

Modifier and Type	Method	Description
private void	mimicSyncUpAfterDelete()
private void	mimicSyncUpAfterPut()
private void	putAndReplicateRows()
void	testStartANewSyncUpToolAfterFailed()	test "start a new ReplicationSyncUp after the previous failed".
void	testSyncUpTool()	Add a row to a table in each cluster, check it's replicated, delete it, check's gone Also check the puts and deletes are not replicated back to the originating cluster.

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

customizeClusterConf, restartSourceHBaseCluster, restartTargetHBaseCluster, setUp, setupReplication, shutDownSourceHBaseCluster, shutDownTargetHBaseCluster, syncUp, syncUp, tearDown

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

Constructor Details

TestReplicationSyncUpTool

public TestReplicationSyncUpTool()

Method Details

testSyncUpTool

@Test
public void testSyncUpTool()
                    throws Exception

Add a row to a table in each cluster, check it's replicated, delete it, check's gone Also check the puts and deletes are not replicated back to the originating cluster.

Throws:

Exception

putAndReplicateRows

private void putAndReplicateRows()
                          throws Exception

Throws:

Exception

mimicSyncUpAfterDelete

private void mimicSyncUpAfterDelete()
                             throws Exception

Throws:

Exception

mimicSyncUpAfterPut

private void mimicSyncUpAfterPut()
                          throws Exception

Throws:

Exception

testStartANewSyncUpToolAfterFailed

@Test
public void testStartANewSyncUpToolAfterFailed()
                                        throws Exception

test "start a new ReplicationSyncUp after the previous failed". See HBASE-27623 for details.

Throws:

Exception