public class TestSplitLogManager
extends java.lang.Object
Constructor and Description |
---|
TestSplitLogManager() |
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() |
public void setup() throws java.lang.Exception
java.lang.Exception
public void teardown() throws java.io.IOException, KeeperException
java.io.IOException
KeeperException
public void testTaskCreation() throws java.lang.Exception
java.lang.Exception
public void testOrphanTaskAcquisition() throws java.lang.Exception
java.lang.Exception
public void testUnassignedOrphan() throws java.lang.Exception
java.lang.Exception
public void testMultipleResubmits() throws java.lang.Exception
java.lang.Exception
public void testRescanCleanup() throws java.lang.Exception
java.lang.Exception
public void testTaskDone() throws java.lang.Exception
java.lang.Exception
public void testTaskErr() throws java.lang.Exception
java.lang.Exception
public void testTaskResigned() throws java.lang.Exception
java.lang.Exception
public void testUnassignedTimeout() throws java.lang.Exception
java.lang.Exception
public void testDeadWorker() throws java.lang.Exception
java.lang.Exception
public void testWorkerCrash() throws java.lang.Exception
java.lang.Exception
public void testEmptyLogDir() throws java.lang.Exception
java.lang.Exception
public void testLogFilesAreArchived() throws java.lang.Exception
java.lang.Exception
public void testRecoveryRegionRemovedFromZK() throws java.lang.Exception
java.lang.Exception
public void testGetPreviousRecoveryMode() throws java.lang.Exception
java.lang.Exception