org.apache.hadoop.hbase.master

Class TestDistributedLogSplitting

java.lang.Object

org.apache.hadoop.hbase.master.TestDistributedLogSplitting

public class TestDistributedLogSplitting
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
TestDistributedLogSplitting()

Method Summary

Modifier and Type	Method and Description
void	after()
void	before()
void	makeWAL(HRegionServer hrs, java.util.List<HRegionInfo> regions, java.lang.String tname, java.lang.String fname, int num_edits, int edit_size)
void	makeWAL(HRegionServer hrs, java.util.List<HRegionInfo> regions, java.lang.String tname, java.lang.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 java.lang.Exception

Throws:

java.lang.Exception

tearDown

public static void tearDown()
                     throws java.io.IOException

Throws:

java.io.IOException

before

public void before()
            throws java.lang.Exception

Throws:

java.lang.Exception

after

public void after()
           throws java.lang.Exception

Throws:

java.lang.Exception

testRecoveredEdits

public void testRecoveredEdits()
                        throws java.lang.Exception

Throws:

java.lang.Exception

testLogReplayWithNonMetaRSDown

public void testLogReplayWithNonMetaRSDown()
                                    throws java.lang.Exception

Throws:

java.lang.Exception

testNonceRecovery

public void testNonceRecovery()
                       throws java.lang.Exception

Throws:

java.lang.Exception

testLogReplayWithMetaRSDown

public void testLogReplayWithMetaRSDown()
                                 throws java.lang.Exception

Throws:

java.lang.Exception

testMasterStartsUpWithLogSplittingWork

public void testMasterStartsUpWithLogSplittingWork()
                                            throws java.lang.Exception

Throws:

java.lang.Exception

testMasterStartsUpWithLogReplayWork

public void testMasterStartsUpWithLogReplayWork()
                                         throws java.lang.Exception

Throws:

java.lang.Exception

testLogReplayTwoSequentialRSDown

public void testLogReplayTwoSequentialRSDown()
                                      throws java.lang.Exception

Throws:

java.lang.Exception

testMarkRegionsRecoveringInZK

public void testMarkRegionsRecoveringInZK()
                                   throws java.lang.Exception

Throws:

java.lang.Exception

testReplayCmd

public void testReplayCmd()
                   throws java.lang.Exception

Throws:

java.lang.Exception

testLogReplayForDisablingTable

public void testLogReplayForDisablingTable()
                                    throws java.lang.Exception

Throws:

java.lang.Exception

testDisallowWritesInRecovering

public void testDisallowWritesInRecovering()
                                    throws java.lang.Exception

Throws:

java.lang.Exception

testWorkerAbort

public void testWorkerAbort()
                     throws java.lang.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:

java.lang.Exception

testThreeRSAbort

public void testThreeRSAbort()
                      throws java.lang.Exception

Throws:

java.lang.Exception

testDelayedDeleteOnFailure

public void testDelayedDeleteOnFailure()
                                throws java.lang.Exception

Throws:

java.lang.Exception

testMetaRecoveryInZK

public void testMetaRecoveryInZK()
                          throws java.lang.Exception

Throws:

java.lang.Exception

testSameVersionUpdatesRecovery

public void testSameVersionUpdatesRecovery()
                                    throws java.lang.Exception

Throws:

java.lang.Exception

testSameVersionUpdatesRecoveryWithCompaction

public void testSameVersionUpdatesRecoveryWithCompaction()
                                                  throws java.lang.Exception

Throws:

java.lang.Exception

testReadWriteSeqIdFiles

public void testReadWriteSeqIdFiles()
                             throws java.lang.Exception

Throws:

java.lang.Exception

makeWAL

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

Throws:

java.io.IOException

makeWAL

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

Throws:

java.io.IOException