Package org.apache.hadoop.hbase.replication.master

Class TestRecoverStandbyProcedure

java.lang.Object

org.apache.hadoop.hbase.replication.master.TestRecoverStandbyProcedure

@Tag("org.apache.hadoop.hbase.testclassification.MasterTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestRecoverStandbyProcedure
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static org.apache.hadoop.conf.Configuration	conf
private static final byte[]	family
private static org.apache.hadoop.fs.FileSystem	fs
private static final org.slf4j.Logger	LOG
private static final String	PEER_ID
private static org.apache.hadoop.hbase.procedure2.ProcedureExecutor<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>	procExec
private static final byte[]	qualifier
private static final org.apache.hadoop.hbase.client.RegionInfo	regionInfo
private static final int	ROW_COUNT
private static final int	RS_NUMBER
private static org.apache.hadoop.hbase.master.replication.SyncReplicationReplayWALManager	syncReplicationReplayWALManager
private static final org.apache.hadoop.hbase.TableName	tableName
private static final long	timestamp
private static final HBaseTestingUtil	UTIL
private static final int	WAL_NUMBER

Constructor Summary

Constructors

Constructor	Description
TestRecoverStandbyProcedure()

Method Summary

Modifier and Type	Method	Description
static void	cleanupTest()
private org.apache.hadoop.hbase.wal.WAL.Entry	createWALEntry(byte[] row, byte[] value)
void	setupBeforeTest()
static void	setupCluster()
private void	setupSyncReplicationWALs()
private List<org.apache.hadoop.hbase.wal.WAL.Entry>	setupWALEntries(int startRow, int endRow)
void	tearDownAfterTest()
void	testRecoverStandby()

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

tableName

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

regionInfo

private static final org.apache.hadoop.hbase.client.RegionInfo regionInfo

family

private static final byte[] family

qualifier

private static final byte[] qualifier

timestamp

private static final long timestamp

ROW_COUNT

private static final int ROW_COUNT

See Also:

• Constant Field Values

WAL_NUMBER

private static final int WAL_NUMBER

See Also:

• Constant Field Values

RS_NUMBER

private static final int RS_NUMBER

See Also:

• Constant Field Values

PEER_ID

private static final String PEER_ID

See Also:

• Constant Field Values

UTIL

private static final HBaseTestingUtil UTIL

syncReplicationReplayWALManager

private static org.apache.hadoop.hbase.master.replication.SyncReplicationReplayWALManager syncReplicationReplayWALManager

procExec

private static org.apache.hadoop.hbase.procedure2.ProcedureExecutor<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv> procExec

fs

private static org.apache.hadoop.fs.FileSystem fs

conf

private static org.apache.hadoop.conf.Configuration conf

Constructor Details

TestRecoverStandbyProcedure

public TestRecoverStandbyProcedure()

Method Details

setupCluster

@BeforeAll
public static void setupCluster()
                         throws Exception

Throws:

Exception

cleanupTest

@AfterAll
public static void cleanupTest()
                        throws Exception

Throws:

Exception

setupBeforeTest

@BeforeEach
public void setupBeforeTest()
                     throws IOException

Throws:

IOException

tearDownAfterTest

@AfterEach
public void tearDownAfterTest()
                       throws IOException

Throws:

IOException

testRecoverStandby

@Test
public void testRecoverStandby()
                        throws IOException,
org.apache.hadoop.hbase.util.CommonFSUtils.StreamLacksCapabilityException

Throws:

IOException

org.apache.hadoop.hbase.util.CommonFSUtils.StreamLacksCapabilityException

setupSyncReplicationWALs

private void setupSyncReplicationWALs()
                               throws IOException,
org.apache.hadoop.hbase.util.CommonFSUtils.StreamLacksCapabilityException

Throws:

IOException

org.apache.hadoop.hbase.util.CommonFSUtils.StreamLacksCapabilityException

setupWALEntries

private List<org.apache.hadoop.hbase.wal.WAL.Entry> setupWALEntries(int startRow,
 int endRow)

createWALEntry

private org.apache.hadoop.hbase.wal.WAL.Entry createWALEntry(byte[] row,
 byte[] value)