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

Class TestMigrateReplicationQueueFromZkToTableProcedureRecovery

java.lang.Object

org.apache.hadoop.hbase.master.replication.TestMigrateReplicationQueueFromZkToTableProcedureRecovery

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

Field Summary

Fields

Modifier and Type	Field	Description
private static final HBaseTestingUtil	UTIL

Constructor Summary

Constructors

Constructor	Description
TestMigrateReplicationQueueFromZkToTableProcedureRecovery()

Method Summary

Modifier and Type	Method	Description
static void	cleanupTest()
private String	getHFileRefsZNode()
private org.apache.hadoop.hbase.procedure2.ProcedureExecutor<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv>	getMasterProcedureExecutor()
void	setup()
static void	setupCluster()
void	tearDown()
void	testRecoveryAndDoubleExecution()

Methods inherited from class java.lang.Object

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

Field Details

UTIL

private static final HBaseTestingUtil UTIL

Constructor Details

TestMigrateReplicationQueueFromZkToTableProcedureRecovery

public TestMigrateReplicationQueueFromZkToTableProcedureRecovery()

Method Details

setupCluster

@BeforeAll
public static void setupCluster()
                         throws Exception

Throws:

Exception

cleanupTest

@AfterAll
public static void cleanupTest()
                        throws Exception

Throws:

Exception

getMasterProcedureExecutor

private org.apache.hadoop.hbase.procedure2.ProcedureExecutor<org.apache.hadoop.hbase.master.procedure.MasterProcedureEnv> getMasterProcedureExecutor()

setup

@BeforeEach
public void setup()
           throws Exception

Throws:

Exception

tearDown

@AfterEach
public void tearDown()
              throws Exception

Throws:

Exception

getHFileRefsZNode

private String getHFileRefsZNode()
                          throws IOException

Throws:

IOException

testRecoveryAndDoubleExecution

@Test
public void testRecoveryAndDoubleExecution()
                                    throws Exception

Throws:

Exception