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
FieldsModifier and TypeFieldDescriptionprivate static final org.slf4j.Loggerprivate final booleanprivate static HBaseTestingUtilprivate String -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate voidassertRegionsAssigned(SingleProcessHBaseCluster cluster, Set<String> expectedRegions) private NavigableSet<String>private intprivate booleanisDeadServerSCPExecuted(org.apache.hadoop.hbase.ServerName serverName) Checks if the SCP of specific dead server has been executed.private voidstatic Stream<org.junit.jupiter.params.provider.Arguments>voidsetTestMethod(org.junit.jupiter.api.TestInfo testInfo) voidprivate voidwaitForRSShutdownToStartAndFinish(org.apache.hadoop.hbase.util.JVMClusterUtil.MasterThread activeMaster, org.apache.hadoop.hbase.ServerName serverName)
-
Field Details
-
LOG
-
TEST_UTIL
-
testMethodName
-
splitWALCoordinatedByZK
-
-
Constructor Details
-
TestRollingRestart
-
-
Method Details
-
setTestMethod
-
testBasicRollingRestart
- 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:
InterruptedExceptionIOException
-
log
-
getNumberOfOnlineRegions
-
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
-