Package org.apache.hadoop.hbase.regionserver.regionreplication

Class TestRegionReplicationForFlushMarker

java.lang.Object

org.apache.hadoop.hbase.regionserver.regionreplication.TestRegionReplicationForFlushMarker

public class TestRegionReplicationForFlushMarker
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	TestRegionReplicationForFlushMarker.ErrorReplayRSRpcServices
static final class	TestRegionReplicationForFlushMarker.HRegionForTest
static final class	TestRegionReplicationForFlushMarker.RSForTest

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static final byte[]	FAMILY
private static final HBaseTestingUtil	HTU
private static final int	NB_SERVERS
private static final byte[]	QUAL
private static boolean	startTest
private static org.apache.hadoop.hbase.TableName	tableName

Constructor Summary

Constructors

Constructor	Description
TestRegionReplicationForFlushMarker()

Method Summary

Modifier and Type	Method	Description
private TestRegionReplicationForFlushMarker.HRegionForTest[]	createTable()
static void	setUp()
static void	tearDown()
void	testCannotFlushMarker()	This test is for HBASE-26960, before HBASE-26960, MemStoreFlusher does not write the WALProtos.FlushDescriptor.FlushAction.CANNOT_FLUSH marker to the WAL when the memstore is empty,so if the RegionReplicationSink request a flush when the memstore is empty, it could not receive the WALProtos.FlushDescriptor.FlushAction.CANNOT_FLUSH and the replication may be hanged.

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

FAMILY

private static final byte[] FAMILY

QUAL

private static final byte[] QUAL

HTU

private static final HBaseTestingUtil HTU

NB_SERVERS

private static final int NB_SERVERS

See Also:

• Constant Field Values

tableName

private static org.apache.hadoop.hbase.TableName tableName

startTest

private static volatile boolean startTest

Constructor Details

TestRegionReplicationForFlushMarker

public TestRegionReplicationForFlushMarker()

Method Details

setUp

public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

public static void tearDown()
                     throws Exception

Throws:

Exception

testCannotFlushMarker

public void testCannotFlushMarker()
                           throws Exception

This test is for HBASE-26960, before HBASE-26960, MemStoreFlusher does not write the WALProtos.FlushDescriptor.FlushAction.CANNOT_FLUSH marker to the WAL when the memstore is empty,so if the RegionReplicationSink request a flush when the memstore is empty, it could not receive the WALProtos.FlushDescriptor.FlushAction.CANNOT_FLUSH and the replication may be hanged. After HBASE-26768,when the RegionReplicationSink request a flush when the memstore is empty,even it does not writes the WALProtos.FlushDescriptor.FlushAction.CANNOT_FLUSH marker to the WAL,we also replicate the WALProtos.FlushDescriptor.FlushAction.CANNOT_FLUSH marker to the secondary region replica.

Throws:

Exception

createTable

private TestRegionReplicationForFlushMarker.HRegionForTest[] createTable()
                                                                  throws Exception

Throws:

Exception