Package org.apache.hadoop.hbase.master

Class TestRollingRestart

java.lang.Object

org.apache.hadoop.hbase.master.TestRollingRestart

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

Tests the restarting of everything as done during rolling restarts.

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private final boolean	splitWALCoordinatedByZK
private static HBaseTestingUtil	TEST_UTIL
private String	testMethodName

Constructor Summary

Constructors

Constructor	Description
TestRollingRestart(boolean splitWALCoordinatedByZK)

Method Summary

Modifier and Type	Method	Description
private void	assertRegionsAssigned(SingleProcessHBaseCluster cluster, Set<String> expectedRegions)
private NavigableSet<String>	getDoubleAssignedRegions(SingleProcessHBaseCluster cluster)
private int	getNumberOfOnlineRegions(SingleProcessHBaseCluster cluster)
private boolean	isDeadServerSCPExecuted(org.apache.hadoop.hbase.ServerName serverName)	Checks if the SCP of specific dead server has been executed.
private void	log(String msg)
static Stream<org.junit.jupiter.params.provider.Arguments>	parameters()
void	setTestMethod(org.junit.jupiter.api.TestInfo testInfo)
void	testBasicRollingRestart()
private void	waitForRSShutdownToStartAndFinish(org.apache.hadoop.hbase.util.JVMClusterUtil.MasterThread activeMaster, org.apache.hadoop.hbase.ServerName serverName)

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

TEST_UTIL

private static HBaseTestingUtil TEST_UTIL

testMethodName

private String testMethodName

splitWALCoordinatedByZK

private final boolean splitWALCoordinatedByZK

Constructor Details

TestRollingRestart

public TestRollingRestart(boolean splitWALCoordinatedByZK)

Method Details

setTestMethod

@BeforeEach
public void setTestMethod(org.junit.jupiter.api.TestInfo testInfo)

testBasicRollingRestart

@TestTemplate
public void testBasicRollingRestart()
                             throws Exception

Throws:

Exception

isDeadServerSCPExecuted

private boolean isDeadServerSCPExecuted(org.apache.hadoop.hbase.ServerName serverName)
                                 throws IOException

Checks if the SCP of specific dead server has been executed.

Returns:

true if the SCP of specific serverName has been executed, false if not

Throws:

IOException

waitForRSShutdownToStartAndFinish

private void waitForRSShutdownToStartAndFinish(org.apache.hadoop.hbase.util.JVMClusterUtil.MasterThread activeMaster,
 org.apache.hadoop.hbase.ServerName serverName)
                                        throws InterruptedException,
IOException

Throws:

InterruptedException

IOException

log

private void log(String msg)

getNumberOfOnlineRegions

private int getNumberOfOnlineRegions(SingleProcessHBaseCluster cluster)

assertRegionsAssigned

private void assertRegionsAssigned(SingleProcessHBaseCluster cluster,
 Set<String> expectedRegions)
                            throws IOException

Throws:

IOException

getDoubleAssignedRegions

private NavigableSet<String> getDoubleAssignedRegions(SingleProcessHBaseCluster cluster)
                                               throws IOException

Throws:

IOException

parameters

public static Stream<org.junit.jupiter.params.provider.Arguments> parameters()