org.apache.hadoop.hbase

Class TestZooKeeper

java.lang.Object

org.apache.hadoop.hbase.TestZooKeeper

public class TestZooKeeper
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	TestZooKeeper.MockLoadBalancer

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static org.slf4j.Logger	LOG
org.junit.rules.TestName	name
private static HBaseTestingUtility	TEST_UTIL

Constructor Summary

Constructors

Constructor and Description
TestZooKeeper()

Method Summary

Modifier and Type	Method and Description
void	after()
private int	countListeners(org.apache.hadoop.hbase.zookeeper.ZKWatcher watcher, Class<?>... exclude) Count listeners in zkw excluding provided classes
private int	countPermanentListeners(org.apache.hadoop.hbase.zookeeper.ZKWatcher watcher) Count listeners in zkw excluding listeners, that belongs to workers or other temporary processes.
void	setUp()
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testLogSplittingAfterMasterRecoveryDueToZKExpiry() Tests whether the logs are split when master recovers from a expired zookeeper session and an RS goes down.
void	testMasterSessionExpired()
void	testMasterZKSessionRecoveryFailure() Master recovery when the znode already exists.
void	testRegionAssignmentAfterMasterRecoveryDueToZKExpiry() Tests that the master does not call retainAssignment after recovery from expired zookeeper session.
void	testRegionServerSessionExpired()
private void	testSanity(String testName) Make sure we can use the cluster

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

TEST_UTIL

private static final HBaseTestingUtility TEST_UTIL

name

public org.junit.rules.TestName name

Constructor Detail

TestZooKeeper

public TestZooKeeper()

Method Detail

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

setUp

public void setUp()
           throws Exception

Throws:

Exception

after

public void after()
           throws Exception

Throws:

Exception

testRegionServerSessionExpired

public void testRegionServerSessionExpired()
                                    throws Exception

Throws:

Exception

testMasterSessionExpired

public void testMasterSessionExpired()
                              throws Exception

Throws:

Exception

testMasterZKSessionRecoveryFailure

public void testMasterZKSessionRecoveryFailure()
                                        throws Exception

Master recovery when the znode already exists. Internally, this test differs from testMasterSessionExpired() because here the master znode will exist in ZK.

Throws:

Exception

testSanity

private void testSanity(String testName)
                 throws Exception

Make sure we can use the cluster

Throws:

Exception

testRegionAssignmentAfterMasterRecoveryDueToZKExpiry

public void testRegionAssignmentAfterMasterRecoveryDueToZKExpiry()
                                                          throws Exception

Tests that the master does not call retainAssignment after recovery from expired zookeeper session. Without the HBASE-6046 fix master always tries to assign all the user regions by calling retainAssignment.

Throws:

Exception

countPermanentListeners

private int countPermanentListeners(org.apache.hadoop.hbase.zookeeper.ZKWatcher watcher)

Count listeners in zkw excluding listeners, that belongs to workers or other temporary processes.

countListeners

private int countListeners(org.apache.hadoop.hbase.zookeeper.ZKWatcher watcher,
                           Class<?>... exclude)

Count listeners in zkw excluding provided classes

testLogSplittingAfterMasterRecoveryDueToZKExpiry

public void testLogSplittingAfterMasterRecoveryDueToZKExpiry()
                                                      throws Exception

Tests whether the logs are split when master recovers from a expired zookeeper session and an RS goes down.

Throws:

Exception