org.apache.hadoop.hbase.master

Class TestSplitLogManager

java.lang.Object

org.apache.hadoop.hbase.master.TestSplitLogManager

public class TestSplitLogManager
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
TestSplitLogManager()

Method Summary

Modifier and Type	Method and Description
void	setup()
void	teardown()
void	testDeadWorker()
void	testEmptyLogDir()
void	testGetPreviousRecoveryMode()
void	testLogFilesAreArchived()
void	testMultipleResubmits()
void	testOrphanTaskAcquisition()
void	testRecoveryRegionRemovedFromZK() The following test case is aiming to test the situation when distributedLogReplay is turned off and restart a cluster there should no recovery regions in ZK left.
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()

Methods inherited from class java.lang.Object

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

Constructor Detail

TestSplitLogManager

public TestSplitLogManager()

Method Detail

setup

public void setup()
           throws java.lang.Exception

Throws:

java.lang.Exception

teardown

public void teardown()
              throws java.io.IOException,
                     KeeperException

Throws:

java.io.IOException

KeeperException

testTaskCreation

public void testTaskCreation()
                      throws java.lang.Exception

Test whether the splitlog correctly creates a task in zookeeper

Throws:

java.lang.Exception

testOrphanTaskAcquisition

public void testOrphanTaskAcquisition()
                               throws java.lang.Exception

Throws:

java.lang.Exception

testUnassignedOrphan

public void testUnassignedOrphan()
                          throws java.lang.Exception

Throws:

java.lang.Exception

testMultipleResubmits

public void testMultipleResubmits()
                           throws java.lang.Exception

Throws:

java.lang.Exception

testRescanCleanup

public void testRescanCleanup()
                       throws java.lang.Exception

Throws:

java.lang.Exception

testTaskDone

public void testTaskDone()
                  throws java.lang.Exception

Throws:

java.lang.Exception

testTaskErr

public void testTaskErr()
                 throws java.lang.Exception

Throws:

java.lang.Exception

testTaskResigned

public void testTaskResigned()
                      throws java.lang.Exception

Throws:

java.lang.Exception

testUnassignedTimeout

public void testUnassignedTimeout()
                           throws java.lang.Exception

Throws:

java.lang.Exception

testDeadWorker

public void testDeadWorker()
                    throws java.lang.Exception

Throws:

java.lang.Exception

testWorkerCrash

public void testWorkerCrash()
                     throws java.lang.Exception

Throws:

java.lang.Exception

testEmptyLogDir

public void testEmptyLogDir()
                     throws java.lang.Exception

Throws:

java.lang.Exception

testLogFilesAreArchived

public void testLogFilesAreArchived()
                             throws java.lang.Exception

Throws:

java.lang.Exception

testRecoveryRegionRemovedFromZK

public void testRecoveryRegionRemovedFromZK()
                                     throws java.lang.Exception

The following test case is aiming to test the situation when distributedLogReplay is turned off and restart a cluster there should no recovery regions in ZK left.

Throws:

java.lang.Exception

testGetPreviousRecoveryMode

public void testGetPreviousRecoveryMode()
                                 throws java.lang.Exception

Throws:

java.lang.Exception