public class TestLogRolling extends AbstractTestLogRolling
Modifier and Type | Class and Description |
---|---|
static class |
TestLogRolling.SlowSyncLogWriter |
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
private static org.slf4j.Logger |
LOG |
admin, cluster, dfsCluster, EXECUTOR, fs, name, server, syncLatencyMillis, tableName, TEST_UTIL, value
Constructor and Description |
---|
TestLogRolling() |
Modifier and Type | Method and 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() |
checkSlowSync, createTestTable, doPut, getName, getWALAndRegisterSlowSyncHook, setUp, tearDown, tearDownAfterClass, testCompactionRecordDoesntBlockRolling, testLogRolling, testLogRollOnNothingWritten, validateData, writeData
public static final HBaseClassTestRule CLASS_RULE
private static final org.slf4j.Logger LOG
public TestLogRolling()
public static void setUpBeforeClass() throws Exception
Exception
protected void setSlowLogWriter(org.apache.hadoop.conf.Configuration conf)
setSlowLogWriter
in class AbstractTestLogRolling
protected void setDefaultLogWriter(org.apache.hadoop.conf.Configuration conf)
setDefaultLogWriter
in class AbstractTestLogRolling
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
IOException
public void testSlowSyncLogRolling() throws Exception
Exception
public void testLogRollOnDatanodeDeath() throws Exception
Exception
public void testLogRollOnPipelineRestart() throws Exception
Exception
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.