Package org.apache.hadoop.hbase.regionserver

Class TestRegionReplicaReplicationError

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestRegionReplicaReplicationError

public class TestRegionReplicaReplicationError
extends Object

Test region replication when error occur.

We can not simply move the secondary replicas as we will trigger a flush for the primary replica when secondary replica is online, which will always make the data of the two regions in sync. So here we need to simulate request errors.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	TestRegionReplicaReplicationError.ErrorReplayRSRpcServices
static final class	TestRegionReplicaReplicationError.RSForTest

Field Summary

Fields

Modifier and Type	Field	Description
private static byte[]	CF
static final HBaseClassTestRule	CLASS_RULE
private static byte[]	CQ
private static final HBaseTestingUtil	HTU
private static String	TN

Constructor Summary

Constructors

Constructor	Description
TestRegionReplicaReplicationError()

Method Summary

Modifier and Type	Method	Description
private boolean	checkReplica(org.apache.hadoop.hbase.client.Table table, int replicaId)
private void	doTest(boolean skipWAL)
static void	setUp()
static void	tearDown()
void	testDefaultDurability()
void	testSkipWAL()

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

HTU

private static final HBaseTestingUtil HTU

TN

private static String TN

CF

private static byte[] CF

CQ

private static byte[] CQ

Constructor Details

TestRegionReplicaReplicationError

public TestRegionReplicaReplicationError()

Method Details

setUp

public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

public static void tearDown()
                     throws Exception

Throws:

Exception

checkReplica

private boolean checkReplica(org.apache.hadoop.hbase.client.Table table,
 int replicaId)
                      throws IOException

Throws:

IOException

testDefaultDurability

public void testDefaultDurability()
                           throws IOException

Throws:

IOException

testSkipWAL

public void testSkipWAL()
                 throws IOException

Throws:

IOException

doTest

private void doTest(boolean skipWAL)
             throws IOException

Throws:

IOException