Package org.apache.hadoop.hbase.tool

Class TestCanaryTool

java.lang.Object

org.apache.hadoop.hbase.tool.TestCanaryTool

@Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestCanaryTool
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static final byte[]	COLUMN
private static final byte[]	FAMILY
private org.apache.logging.log4j.core.Appender	mockAppender
private HBaseTestingUtil	testingUtility

Constructor Summary

Constructors

Constructor	Description
TestCanaryTool()

Method Summary

Modifier and Type	Method	Description
private String	getPageContent(URL url)
private void	runRegionserverCanary()
void	setUp()
private static ExecutorService	startCanaryToolInBackground(org.apache.hadoop.hbase.tool.CanaryTool.RegionStdOutSink sink, org.apache.hadoop.conf.Configuration configuration)
void	tearDown()
void	testBasicCanaryWorks(org.junit.jupiter.api.TestInfo testInfo)
void	testBasicZookeeperCanaryWorks()
void	testCanaryRegionTaskReadAllCF(org.junit.jupiter.api.TestInfo testInfo)
void	testCanaryRegionTaskResult()
void	testCanaryStopsScanningAfterTimeout(org.junit.jupiter.api.TestInfo testInfo)	When CanaryTool times out, it should stop scanning and shutdown quickly and gracefully.
void	testRawScanConfig(org.junit.jupiter.api.TestInfo testInfo)
void	testReadTableTimeouts(org.junit.jupiter.api.TestInfo testInfo)
void	testRegionserverNoRegions()
void	testRegionserverWithRegions(org.junit.jupiter.api.TestInfo testInfo)
void	testWebUI()
void	testWebUIWithFailures()
void	testWriteTableTimeout()
void	testZookeeperCanaryPermittedFailuresArgumentWorks()
private void	testZookeeperCanaryWithArgs(String[] args)

Methods inherited from class java.lang.Object

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

Field Details

testingUtility

private HBaseTestingUtil testingUtility

FAMILY

private static final byte[] FAMILY

COLUMN

private static final byte[] COLUMN

mockAppender

private org.apache.logging.log4j.core.Appender mockAppender

Constructor Details

TestCanaryTool

public TestCanaryTool()

Method Details

setUp

@BeforeEach
public void setUp()
           throws Exception

Throws:

Exception

tearDown

@AfterEach
public void tearDown()
              throws Exception

Throws:

Exception

testBasicZookeeperCanaryWorks

@Test
public void testBasicZookeeperCanaryWorks()
                                   throws Exception

Throws:

Exception

testZookeeperCanaryPermittedFailuresArgumentWorks

@Test
public void testZookeeperCanaryPermittedFailuresArgumentWorks()
                                                       throws Exception

Throws:

Exception

testBasicCanaryWorks

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

Throws:

Exception

testCanaryStopsScanningAfterTimeout

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

When CanaryTool times out, it should stop scanning and shutdown quickly and gracefully. This test helps to confirm that threadpools do not continue executing work after the canary finishes. It also verifies sink behavior and measures correct failure counts in the sink.

Throws:

Exception - if it can't create a table, communicate with minicluster, or run the canary.

testCanaryRegionTaskReadAllCF

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

Throws:

Exception

testCanaryRegionTaskResult

@Test
public void testCanaryRegionTaskResult()
                                throws Exception

Throws:

Exception

testReadTableTimeouts

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

Throws:

Exception

testWriteTableTimeout

@Test
public void testWriteTableTimeout()
                           throws Exception

Throws:

Exception

testRegionserverNoRegions

@Test
public void testRegionserverNoRegions()
                               throws Exception

Throws:

Exception

testRegionserverWithRegions

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

Throws:

Exception

testRawScanConfig

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

Throws:

Exception

runRegionserverCanary

private void runRegionserverCanary()
                            throws Exception

Throws:

Exception

testZookeeperCanaryWithArgs

private void testZookeeperCanaryWithArgs(String[] args)
                                  throws Exception

Throws:

Exception

testWebUI

@Test
public void testWebUI()
               throws Exception

Throws:

Exception

testWebUIWithFailures

@Test
public void testWebUIWithFailures()
                           throws Exception

Throws:

Exception

startCanaryToolInBackground

private static ExecutorService startCanaryToolInBackground(org.apache.hadoop.hbase.tool.CanaryTool.RegionStdOutSink sink,
 org.apache.hadoop.conf.Configuration configuration)

getPageContent

private String getPageContent(URL url)
                       throws IOException,
InterruptedException

Throws:

IOException

InterruptedException