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

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
static final HBaseClassTestRule	CLASS_RULE
private static org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup	EVENT_LOOP_GROUP
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
org.junit.rules.TestName	name
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()
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

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

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

name

public org.junit.rules.TestName name

RNG

private static final Random RNG

Constructor Details

TestFanOutOneBlockAsyncDFSOutput

public TestFanOutOneBlockAsyncDFSOutput()

Method Details

setUp

public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

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

test

public void test()
          throws IOException,
InterruptedException,
ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

test0Recover

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

public void testHeartbeat()
                   throws IOException,
InterruptedException,
ExecutionException

Throws:

IOException

InterruptedException

ExecutionException

testCreateParentFailed

public void testCreateParentFailed()
                            throws IOException

This is important for fencing when recover from RS crash.

Throws:

IOException

testConnectToDatanodeFailed

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

Throws:

IOException

ClassNotFoundException

NoSuchMethodException

IllegalAccessException

InvocationTargetException

InterruptedException

NoSuchFieldException

testExcludeFailedConnectToDatanode

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

Throws:

IOException

ClassNotFoundException

NoSuchMethodException

IllegalAccessException

InvocationTargetException

InterruptedException

NoSuchFieldException

testWriteLargeChunk

public void testWriteLargeChunk()
                         throws IOException,
InterruptedException,
ExecutionException

Throws:

IOException

InterruptedException

ExecutionException