org.apache.hadoop.hbase.master

Class TestDistributedLogSplitting

java.lang.Object

org.apache.hadoop.hbase.master.TestDistributedLogSplitting

public class TestDistributedLogSplitting
extends Object

Constructor Summary

Constructors

Constructor and Description
TestDistributedLogSplitting()

Method Summary

Modifier and Type	Method and Description
void	after()
void	before()
void	makeWAL(HRegionServer hrs, List<HRegionInfo> regions, String tname, String fname, int num_edits, int edit_size)
void	makeWAL(HRegionServer hrs, List<HRegionInfo> regions, String tname, String fname, int num_edits, int edit_size, boolean cleanShutdown)
static void	setup()
static void	tearDown()
void	testDelayedDeleteOnFailure()
void	testDisallowWritesInRecovering()
void	testLogReplayForDisablingTable()
void	testLogReplayTwoSequentialRSDown()
void	testLogReplayWithMetaRSDown()
void	testLogReplayWithNonMetaRSDown()
void	testMarkRegionsRecoveringInZK()
void	testMasterStartsUpWithLogReplayWork()
void	testMasterStartsUpWithLogSplittingWork()
void	testMetaRecoveryInZK()
void	testNonceRecovery()
void	testReadWriteSeqIdFiles()
void	testRecoveredEdits()
void	testReplayCmd()
void	testSameVersionUpdatesRecovery()
void	testSameVersionUpdatesRecoveryWithCompaction()
void	testThreeRSAbort()
void	testWorkerAbort() The original intention of this test was to force an abort of a region server and to make sure that the failure path in the region servers is properly evaluated.

Methods inherited from class java.lang.Object

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

Constructor Detail

TestDistributedLogSplitting

public TestDistributedLogSplitting()

Method Detail

setup

public static void setup()
                  throws Exception

Throws:

Exception

tearDown

public static void tearDown()
                     throws IOException

Throws:

IOException

before

public void before()
            throws Exception

Throws:

Exception

after

public void after()
           throws Exception

Throws:

Exception

testRecoveredEdits

public void testRecoveredEdits()
                        throws Exception

Throws:

Exception

testLogReplayWithNonMetaRSDown

public void testLogReplayWithNonMetaRSDown()
                                    throws Exception

Throws:

Exception

testNonceRecovery

public void testNonceRecovery()
                       throws Exception

Throws:

Exception

testLogReplayWithMetaRSDown

public void testLogReplayWithMetaRSDown()
                                 throws Exception

Throws:

Exception

testMasterStartsUpWithLogSplittingWork

public void testMasterStartsUpWithLogSplittingWork()
                                            throws Exception

Throws:

Exception

testMasterStartsUpWithLogReplayWork

public void testMasterStartsUpWithLogReplayWork()
                                         throws Exception

Throws:

Exception

testLogReplayTwoSequentialRSDown

public void testLogReplayTwoSequentialRSDown()
                                      throws Exception

Throws:

Exception

testMarkRegionsRecoveringInZK

public void testMarkRegionsRecoveringInZK()
                                   throws Exception

Throws:

Exception

testReplayCmd

public void testReplayCmd()
                   throws Exception

Throws:

Exception

testLogReplayForDisablingTable

public void testLogReplayForDisablingTable()
                                    throws Exception

Throws:

Exception

testDisallowWritesInRecovering

public void testDisallowWritesInRecovering()
                                    throws Exception

Throws:

Exception

testWorkerAbort

public void testWorkerAbort()
                     throws Exception

The original intention of this test was to force an abort of a region server and to make sure that the failure path in the region servers is properly evaluated. But it is difficult to ensure that the region server doesn't finish the log splitting before it aborts. Also now, there is this code path where the master will preempt the region server when master detects that the region server has aborted.

Throws:

Exception

testThreeRSAbort

public void testThreeRSAbort()
                      throws Exception

Throws:

Exception

testDelayedDeleteOnFailure

public void testDelayedDeleteOnFailure()
                                throws Exception

Throws:

Exception

testMetaRecoveryInZK

public void testMetaRecoveryInZK()
                          throws Exception

Throws:

Exception

testSameVersionUpdatesRecovery

public void testSameVersionUpdatesRecovery()
                                    throws Exception

Throws:

Exception

testSameVersionUpdatesRecoveryWithCompaction

public void testSameVersionUpdatesRecoveryWithCompaction()
                                                  throws Exception

Throws:

Exception

testReadWriteSeqIdFiles

public void testReadWriteSeqIdFiles()
                             throws Exception

Throws:

Exception

makeWAL

public void makeWAL(HRegionServer hrs,
                    List<HRegionInfo> regions,
                    String tname,
                    String fname,
                    int num_edits,
                    int edit_size)
             throws IOException

Throws:

IOException

makeWAL

public void makeWAL(HRegionServer hrs,
                    List<HRegionInfo> regions,
                    String tname,
                    String fname,
                    int num_edits,
                    int edit_size,
                    boolean cleanShutdown)
             throws IOException

Throws:

IOException