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
FieldsModifier and TypeFieldDescriptionprivate static Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel>private static org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroupprivate org.apache.hadoop.fs.Pathprivate static org.apache.hadoop.hdfs.DistributedFileSystemprivate static final org.slf4j.Loggerprivate static org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitorprivate static intprivate static final RandomFields inherited from class org.apache.hadoop.hbase.io.asyncfs.AsyncFSTestBase
CLUSTER, CLUSTER_TEST_DIR, UTIL -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic voidsetUp()voidsetUpBeforeEach(org.junit.jupiter.api.TestInfo testInfo) static voidtearDown()voidtest()voidTest method has been renamed to be the first in NAME_ASCENDING.voidvoidThis is important for fencing when recover from RS crash.voidvoidvoid(package private) static voidwriteAndVerify(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
-
Field Details
-
LOG
-
FS
-
EVENT_LOOP_GROUP
-
CHANNEL_CLASS
-
READ_TIMEOUT_MS
-
MONITOR
-
file
-
RNG
-
-
Constructor Details
-
TestFanOutOneBlockAsyncDFSOutput
public TestFanOutOneBlockAsyncDFSOutput()
-
-
Method Details
-
setUp
- Throws:
Exception
-
tearDown
- 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 -
setUpBeforeEach
-
test
-
test0Recover
Test method has been renamed to be the first in NAME_ASCENDING. It's an ugly hack to avoid flakiness. -
testHeartbeat
-
testCreateParentFailed
This is important for fencing when recover from RS crash.- Throws:
IOException
-
testConnectToDatanodeFailed
-
testExcludeFailedConnectToDatanode
-
testWriteLargeChunk
@Test public void testWriteLargeChunk() throws IOException, InterruptedException, ExecutionException
-