Package org.apache.hadoop.hbase

Class TestZooKeeper

java.lang.Object

org.apache.hadoop.hbase.TestZooKeeper

@Tag("org.apache.hadoop.hbase.testclassification.MiscTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
public class TestZooKeeper
extends Object

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private static final HBaseTestingUtil	TEST_UTIL

Constructor Summary

Constructors

Constructor	Description
TestZooKeeper()

Method Summary

Modifier and Type	Method	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(org.junit.jupiter.api.TestInfo testInfo)	Tests whether the logs are split when master recovers from a expired zookeeper session and an RS goes down.
void	testMasterSessionExpired(org.junit.jupiter.api.TestInfo testInfo)
void	testMasterZKSessionRecoveryFailure(org.junit.jupiter.api.TestInfo testInfo)	Master recovery when the znode already exists.
void	testRegionAssignmentAfterMasterRecoveryDueToZKExpiry(org.junit.jupiter.api.TestInfo testInfo)	Tests that the master does not call retainAssignment after recovery from expired zookeeper session.
void	testRegionServerSessionExpired(org.junit.jupiter.api.TestInfo testInfo)
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 Details

LOG

private static final org.slf4j.Logger LOG

TEST_UTIL

private static final HBaseTestingUtil TEST_UTIL

Constructor Details

TestZooKeeper

public TestZooKeeper()

Method Details

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

setUp

@BeforeEach
public void setUp()
           throws Exception

Throws:

Exception

after

@AfterEach
public void after()
           throws Exception

Throws:

Exception

testRegionServerSessionExpired

@Test
public void testRegionServerSessionExpired(org.junit.jupiter.api.TestInfo testInfo)
                                    throws Exception

Throws:

Exception

testMasterSessionExpired

@Test
public void testMasterSessionExpired(org.junit.jupiter.api.TestInfo testInfo)
                              throws Exception

Throws:

Exception

testMasterZKSessionRecoveryFailure

@Test
public void testMasterZKSessionRecoveryFailure(org.junit.jupiter.api.TestInfo testInfo)
                                        throws Exception

Master recovery when the znode already exists. Internally, this test differs from testMasterSessionExpired(org.junit.jupiter.api.TestInfo) 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

@Test
public void testRegionAssignmentAfterMasterRecoveryDueToZKExpiry(org.junit.jupiter.api.TestInfo testInfo)
                                                          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

@Test
public void testLogSplittingAfterMasterRecoveryDueToZKExpiry(org.junit.jupiter.api.TestInfo testInfo)
                                                      throws Exception

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

Throws:

Exception