Package org.apache.hadoop.hbase.regionserver

Class TestRegionReplicaReplicationError

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestRegionReplicaReplicationError

@Tag("org.apache.hadoop.hbase.testclassification.FlakeyTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
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
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

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

@BeforeAll
public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

@AfterAll
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

@Test
public void testDefaultDurability()
                           throws IOException

Throws:

IOException

testSkipWAL

@Test
public void testSkipWAL()
                 throws IOException

Throws:

IOException

doTest

private void doTest(boolean skipWAL)
             throws IOException

Throws:

IOException