Package org.apache.hadoop.hbase.master

Class TestSplitLogManager

java.lang.Object

org.apache.hadoop.hbase.master.TestSplitLogManager

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) class	TestSplitLogManager.DummyMasterServices
private static interface	TestSplitLogManager.Expr

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.conf.Configuration	conf
private static final org.slf4j.Logger	LOG
private TestSplitLogManager.DummyMasterServices	master
private org.apache.hadoop.hbase.master.SplitLogManager	slm
private final org.apache.hadoop.hbase.master.ServerManager	sm
private static HBaseTestingUtil	TEST_UTIL
private int	to
private org.apache.hadoop.hbase.zookeeper.ZKWatcher	zkw

Constructor Summary

Constructors

Constructor	Description
TestSplitLogManager()

Method Summary

Modifier and Type	Method	Description
private org.apache.hadoop.hbase.master.SplitLogManager.Task	findOrCreateOrphanTask(String path)
void	setup()
private String	submitTaskAndWait(org.apache.hadoop.hbase.master.SplitLogManager.TaskBatch batch, String name)
void	teardown()
void	testBatchWaitMillis()
void	testDeadWorker()
void	testEmptyLogDir()
void	testLogFilesAreArchived()
void	testMultipleResubmits()
void	testOrphanTaskAcquisition()
void	testRescanCleanup()
void	testTaskCreation()	Test whether the splitlog correctly creates a task in zookeeper
void	testTaskDone()
void	testTaskErr()
void	testTaskResigned()
void	testUnassignedOrphan()
void	testUnassignedTimeout()
void	testWorkerCrash()
private void	waitForCounter(LongAdder ctr, long oldval, long newval, long timems)
private void	waitForCounter(TestSplitLogManager.Expr e, long oldval, long newval, long timems)

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

sm

private final org.apache.hadoop.hbase.master.ServerManager sm

zkw

private org.apache.hadoop.hbase.zookeeper.ZKWatcher zkw

master

private TestSplitLogManager.DummyMasterServices master

slm

private org.apache.hadoop.hbase.master.SplitLogManager slm

conf

private org.apache.hadoop.conf.Configuration conf

to

private int to

TEST_UTIL

private static HBaseTestingUtil TEST_UTIL

Constructor Details

TestSplitLogManager

public TestSplitLogManager()

Method Details

setup

@BeforeEach
public void setup()
           throws Exception

Throws:

Exception

teardown

@AfterEach
public void teardown()
              throws IOException,
org.apache.zookeeper.KeeperException

Throws:

IOException

org.apache.zookeeper.KeeperException

testBatchWaitMillis

@Test
public void testBatchWaitMillis()

waitForCounter

private void waitForCounter(LongAdder ctr,
 long oldval,
 long newval,
 long timems)
                     throws Exception

Throws:

Exception

waitForCounter

private void waitForCounter(TestSplitLogManager.Expr e,
 long oldval,
 long newval,
 long timems)
                     throws Exception

Throws:

Exception

findOrCreateOrphanTask

private org.apache.hadoop.hbase.master.SplitLogManager.Task findOrCreateOrphanTask(String path)

submitTaskAndWait

private String submitTaskAndWait(org.apache.hadoop.hbase.master.SplitLogManager.TaskBatch batch,
 String name)
                          throws org.apache.zookeeper.KeeperException,
InterruptedException

Throws:

org.apache.zookeeper.KeeperException

InterruptedException

testTaskCreation

@Test
public void testTaskCreation()
                      throws Exception

Test whether the splitlog correctly creates a task in zookeeper

Throws:

Exception

testOrphanTaskAcquisition

@Test
public void testOrphanTaskAcquisition()
                               throws Exception

Throws:

Exception

testUnassignedOrphan

@Test
public void testUnassignedOrphan()
                          throws Exception

Throws:

Exception

testMultipleResubmits

@Test
public void testMultipleResubmits()
                           throws Exception

Throws:

Exception

testRescanCleanup

@Test
public void testRescanCleanup()
                       throws Exception

Throws:

Exception

testTaskDone

@Test
public void testTaskDone()
                  throws Exception

Throws:

Exception

testTaskErr

@Test
public void testTaskErr()
                 throws Exception

Throws:

Exception

testTaskResigned

@Test
public void testTaskResigned()
                      throws Exception

Throws:

Exception

testUnassignedTimeout

@Test
public void testUnassignedTimeout()
                           throws Exception

Throws:

Exception

testDeadWorker

@Test
public void testDeadWorker()
                    throws Exception

Throws:

Exception

testWorkerCrash

@Test
public void testWorkerCrash()
                     throws Exception

Throws:

Exception

testEmptyLogDir

@Test
public void testEmptyLogDir()
                     throws Exception

Throws:

Exception

testLogFilesAreArchived

@Test
public void testLogFilesAreArchived()
                             throws Exception

Throws:

Exception