Package org.apache.hadoop.hbase.io.asyncfs

Class TestFanOutOneBlockAsyncDFSOutput

java.lang.Object

org.apache.hadoop.hbase.io.asyncfs.AsyncFSTestBase

org.apache.hadoop.hbase.io.asyncfs.TestFanOutOneBlockAsyncDFSOutput

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

Field Summary

Fields

Modifier and Type	Field	Description
private static Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel>	CHANNEL_CLASS
private static org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup	EVENT_LOOP_GROUP
private org.apache.hadoop.fs.Path	file
private static org.apache.hadoop.hdfs.DistributedFileSystem	FS
private static final org.slf4j.Logger	LOG
private static org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor	MONITOR
private static int	READ_TIMEOUT_MS
private static final Random	RNG

Fields inherited from class org.apache.hadoop.hbase.io.asyncfs.AsyncFSTestBase

CLUSTER, CLUSTER_TEST_DIR, UTIL

Constructor Summary

Constructors

Constructor	Description
TestFanOutOneBlockAsyncDFSOutput()

Method Summary

Modifier and Type	Method	Description
static void	setUp()
void	setUpBeforeEach(org.junit.jupiter.api.TestInfo testInfo)
static void	tearDown()
void	test()
void	test0Recover()	Test method has been renamed to be the first in NAME_ASCENDING.
void	testConnectToDatanodeFailed()
void	testCreateParentFailed()	This is important for fencing when recover from RS crash.
void	testExcludeFailedConnectToDatanode()
void	testHeartbeat()
void	testWriteLargeChunk()
(package private) static void	writeAndVerify(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path f, org.apache.hadoop.hbase.io.asyncfs.AsyncFSOutput out)

Methods inherited from class org.apache.hadoop.hbase.io.asyncfs.AsyncFSTestBase

setupClusterTestDir, shutdownMiniDFSCluster, startMiniDFSCluster

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

FS

private static org.apache.hadoop.hdfs.DistributedFileSystem FS

EVENT_LOOP_GROUP

private static org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup EVENT_LOOP_GROUP

CHANNEL_CLASS

private static Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> CHANNEL_CLASS

READ_TIMEOUT_MS

private static int READ_TIMEOUT_MS

MONITOR

private static org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor MONITOR

file

private org.apache.hadoop.fs.Path file

RNG

private static final Random RNG

Constructor Details

TestFanOutOneBlockAsyncDFSOutput

public TestFanOutOneBlockAsyncDFSOutput()

Method Details

setUp

@BeforeAll
public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

@AfterAll
public static void tearDown()
                     throws Exception

Throws:

Exception

writeAndVerify

static void writeAndVerify(org.apache.hadoop.fs.FileSystem fs,
 org.apache.hadoop.fs.Path f,
 org.apache.hadoop.hbase.io.asyncfs.AsyncFSOutput out)
                    throws IOException,
InterruptedException,
ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

setUpBeforeEach

@BeforeEach
public void setUpBeforeEach(org.junit.jupiter.api.TestInfo testInfo)

test

@Test
public void test()
          throws IOException,
InterruptedException,
ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

test0Recover

@Test
public void test0Recover()
                  throws IOException,
InterruptedException,
ExecutionException

Test method has been renamed to be the first in NAME_ASCENDING. It's an ugly hack to avoid flakiness.

Throws:

IOException

InterruptedException

ExecutionException

testHeartbeat

@Test
public void testHeartbeat()
                   throws IOException,
InterruptedException,
ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

testCreateParentFailed

@Test
public void testCreateParentFailed()
                            throws IOException

This is important for fencing when recover from RS crash.

Throws:

IOException

testConnectToDatanodeFailed

@Test
public void testConnectToDatanodeFailed()
                                 throws IOException,
ClassNotFoundException,
NoSuchMethodException,
IllegalAccessException,
InvocationTargetException,
InterruptedException,
NoSuchFieldException

Throws:

IOException

ClassNotFoundException

NoSuchMethodException

IllegalAccessException

InvocationTargetException

InterruptedException

NoSuchFieldException

testExcludeFailedConnectToDatanode

@Test
public void testExcludeFailedConnectToDatanode()
                                        throws IOException,
ClassNotFoundException,
NoSuchMethodException,
IllegalAccessException,
InvocationTargetException,
InterruptedException,
NoSuchFieldException

Throws:

IOException

ClassNotFoundException

NoSuchMethodException

IllegalAccessException

InvocationTargetException

InterruptedException

NoSuchFieldException

testWriteLargeChunk

@Test
public void testWriteLargeChunk()
                         throws IOException,
InterruptedException,
ExecutionException

Throws:

IOException

InterruptedException

ExecutionException