Package org.apache.hadoop.hbase.regionserver.wal

Class TestLogRolling

java.lang.Object

org.apache.hadoop.hbase.regionserver.wal.AbstractTestLogRolling

org.apache.hadoop.hbase.regionserver.wal.TestLogRolling

@Tag("org.apache.hadoop.hbase.testclassification.VerySlowRegionServerTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestLogRolling
extends AbstractTestLogRolling

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestLogRolling.SlowSyncLogWriter

Field Summary

Fields

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

Fields inherited from class org.apache.hadoop.hbase.regionserver.wal.AbstractTestLogRolling

admin, cluster, dfsCluster, EXECUTOR, fs, server, syncLatencyMillis, tableName, TEST_UTIL, value

Constructor Summary

Constructors

Constructor	Description
TestLogRolling()

Method Summary

Modifier and Type	Method	Description
(package private) void	batchWriteAndWait(org.apache.hadoop.hbase.client.Table table, org.apache.hadoop.hbase.regionserver.wal.FSHLog log, int start, boolean expect, int timeout)
protected void	setDefaultLogWriter(org.apache.hadoop.conf.Configuration conf)
protected void	setSlowLogWriter(org.apache.hadoop.conf.Configuration conf)
static void	setUpBeforeClass()
void	testLogRollOnDatanodeDeath()	Tests that logs are rolled upon detecting datanode death Requires an HDFS jar with HDFS-826 & syncFs() support (HDFS-200)
void	testLogRollOnPipelineRestart()	Test that WAL is rolled when all data nodes in the pipeline have been restarted.
void	testSlowSyncLogRolling()

Methods inherited from class org.apache.hadoop.hbase.regionserver.wal.AbstractTestLogRolling

checkSlowSync, createTestTable, doPut, getName, getWALAndRegisterSlowSyncHook, initTestName, setUp, tearDown, tearDownAfterClass, testCompactionRecordDoesntBlockRolling, testLogRolling, testLogRollOnNothingWritten, validateData, writeData

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

Constructor Details

TestLogRolling

public TestLogRolling()

Method Details

setUpBeforeClass

@BeforeAll
public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

setSlowLogWriter

protected void setSlowLogWriter(org.apache.hadoop.conf.Configuration conf)

Specified by:

setSlowLogWriter in class AbstractTestLogRolling

setDefaultLogWriter

protected void setDefaultLogWriter(org.apache.hadoop.conf.Configuration conf)

Specified by:

setDefaultLogWriter in class AbstractTestLogRolling

batchWriteAndWait

void batchWriteAndWait(org.apache.hadoop.hbase.client.Table table,
 org.apache.hadoop.hbase.regionserver.wal.FSHLog log,
 int start,
 boolean expect,
 int timeout)
                throws IOException

Throws:

IOException

testSlowSyncLogRolling

@Test
public void testSlowSyncLogRolling()
                            throws Exception

Throws:

Exception

testLogRollOnDatanodeDeath

@Test
public void testLogRollOnDatanodeDeath()
                                throws Exception

Tests that logs are rolled upon detecting datanode death Requires an HDFS jar with HDFS-826 & syncFs() support (HDFS-200)

Throws:

Exception

testLogRollOnPipelineRestart

@Test
public void testLogRollOnPipelineRestart()
                                  throws Exception

Test that WAL is rolled when all data nodes in the pipeline have been restarted.

Throws:

Exception