Package org.apache.hadoop.hbase.replication

Class TestReplicationDisableInactivePeer

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationBaseNoBeforeAll

org.apache.hadoop.hbase.replication.TestReplicationBase

org.apache.hadoop.hbase.replication.TestReplicationDisableInactivePeer

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

Nested Class Summary

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

TestReplicationBaseNoBeforeAll.ReplicationEndpointTest

Field Summary

Fields

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

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

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	Description
TestReplicationDisableInactivePeer()

Method Summary

Modifier and Type	Method	Description
protected String	getClusterKey(HBaseTestingUtil util)
void	testDisableInactivePeer()	Test disabling an inactive peer.

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

setUpBeforeClass

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

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

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

TestReplicationDisableInactivePeer

public TestReplicationDisableInactivePeer()

Method Details

getClusterKey

protected String getClusterKey(HBaseTestingUtil util)
                        throws Exception

Overrides:

getClusterKey in class TestReplicationBaseNoBeforeAll

Throws:

Exception

testDisableInactivePeer

@Test
public void testDisableInactivePeer()
                             throws Exception

Test disabling an inactive peer. Add a peer which is inactive, trying to insert, disable the peer, then activate the peer and make sure nothing is replicated. In Addition, enable the peer and check the updates are replicated.

Throws:

Exception