HBASE-9018 Add timeouts on all tests in TestHLogSplit
git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1505817 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Michael Stack
parent
caef0da681
commit
19a311d7ec
|
|
@ -187,7 +187,7 @@ public class TestHLogSplit {
|
|||
* @throws IOException
|
||||
* @throws InterruptedException
|
||||
*/
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testLogCannotBeWrittenOnceParsed() throws IOException, InterruptedException {
|
||||
final AtomicLong counter = new AtomicLong(0);
|
||||
AtomicBoolean stop = new AtomicBoolean(false);
|
||||
|
|
@ -332,7 +332,7 @@ public class TestHLogSplit {
|
|||
* @throws IOException
|
||||
* @see https://issues.apache.org/jira/browse/HBASE-3020
|
||||
*/
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testRecoveredEditsPathForMeta() throws IOException {
|
||||
FileSystem fs = FileSystem.get(TEST_UTIL.getConfiguration());
|
||||
byte [] encoded = HRegionInfo.FIRST_META_REGIONINFO.getEncodedNameAsBytes();
|
||||
|
|
@ -354,7 +354,7 @@ public class TestHLogSplit {
|
|||
* Test old recovered edits file doesn't break HLogSplitter.
|
||||
* This is useful in upgrading old instances.
|
||||
*/
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testOldRecoveredEditsFileSidelined() throws IOException {
|
||||
FileSystem fs = FileSystem.get(TEST_UTIL.getConfiguration());
|
||||
byte [] encoded = HRegionInfo.FIRST_META_REGIONINFO.getEncodedNameAsBytes();
|
||||
|
|
@ -377,7 +377,7 @@ public class TestHLogSplit {
|
|||
HLogFactory.createWriter(fs, p, conf).close();
|
||||
}
|
||||
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testSplitPreservesEdits() throws IOException{
|
||||
final String REGION = "region__1";
|
||||
REGIONS.removeAll(REGIONS);
|
||||
|
|
@ -394,7 +394,7 @@ public class TestHLogSplit {
|
|||
}
|
||||
|
||||
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testEmptyLogFiles() throws IOException {
|
||||
|
||||
injectEmptyFile(".empty", true);
|
||||
|
|
@ -419,7 +419,7 @@ public class TestHLogSplit {
|
|||
}
|
||||
|
||||
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testEmptyOpenLogFiles() throws IOException {
|
||||
injectEmptyFile(".empty", false);
|
||||
generateHLogs(Integer.MAX_VALUE);
|
||||
|
|
@ -442,7 +442,7 @@ public class TestHLogSplit {
|
|||
}
|
||||
}
|
||||
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testOpenZeroLengthReportedFileButWithDataGetsSplit() throws IOException {
|
||||
// generate logs but leave hlog.dat.5 open.
|
||||
generateHLogs(5);
|
||||
|
|
@ -463,7 +463,7 @@ public class TestHLogSplit {
|
|||
}
|
||||
|
||||
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testTralingGarbageCorruptionFileSkipErrorsPasses() throws IOException {
|
||||
conf.setBoolean(HBASE_SKIP_ERRORS, true);
|
||||
generateHLogs(Integer.MAX_VALUE);
|
||||
|
|
@ -484,7 +484,7 @@ public class TestHLogSplit {
|
|||
}
|
||||
}
|
||||
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testFirstLineCorruptionLogFileSkipErrorsPasses() throws IOException {
|
||||
conf.setBoolean(HBASE_SKIP_ERRORS, true);
|
||||
generateHLogs(Integer.MAX_VALUE);
|
||||
|
|
@ -505,7 +505,7 @@ public class TestHLogSplit {
|
|||
}
|
||||
}
|
||||
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testMiddleGarbageCorruptionSkipErrorsReadsHalfOfFile() throws IOException {
|
||||
conf.setBoolean(HBASE_SKIP_ERRORS, true);
|
||||
generateHLogs(Integer.MAX_VALUE);
|
||||
|
|
@ -532,7 +532,7 @@ public class TestHLogSplit {
|
|||
}
|
||||
}
|
||||
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testCorruptedFileGetsArchivedIfSkipErrors() throws IOException {
|
||||
conf.setBoolean(HBASE_SKIP_ERRORS, true);
|
||||
Class<?> backupClass = conf.getClass("hbase.regionserver.hlog.reader.impl",
|
||||
|
|
@ -562,7 +562,7 @@ public class TestHLogSplit {
|
|||
}
|
||||
}
|
||||
|
||||
@Test(expected = IOException.class)
|
||||
@Test (timeout=300000, expected = IOException.class)
|
||||
public void testTrailingGarbageCorruptionLogFileSkipErrorsFalseThrows()
|
||||
throws IOException {
|
||||
conf.setBoolean(HBASE_SKIP_ERRORS, false);
|
||||
|
|
@ -585,7 +585,7 @@ public class TestHLogSplit {
|
|||
}
|
||||
}
|
||||
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testCorruptedLogFilesSkipErrorsFalseDoesNotTouchLogs()
|
||||
throws IOException {
|
||||
conf.setBoolean(HBASE_SKIP_ERRORS, false);
|
||||
|
|
@ -614,7 +614,7 @@ public class TestHLogSplit {
|
|||
}
|
||||
}
|
||||
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testEOFisIgnored() throws IOException {
|
||||
conf.setBoolean(HBASE_SKIP_ERRORS, false);
|
||||
|
||||
|
|
@ -645,7 +645,7 @@ public class TestHLogSplit {
|
|||
assertEquals(archivedLogs.length, 0);
|
||||
}
|
||||
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testCorruptWALTrailer() throws IOException {
|
||||
conf.setBoolean(HBASE_SKIP_ERRORS, false);
|
||||
|
||||
|
|
@ -676,7 +676,7 @@ public class TestHLogSplit {
|
|||
assertEquals(archivedLogs.length, 0);
|
||||
}
|
||||
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testLogsGetArchivedAfterSplit() throws IOException {
|
||||
conf.setBoolean(HBASE_SKIP_ERRORS, false);
|
||||
generateHLogs(-1);
|
||||
|
|
@ -686,7 +686,7 @@ public class TestHLogSplit {
|
|||
assertEquals("wrong number of files in the archive log", NUM_WRITERS, archivedLogs.length);
|
||||
}
|
||||
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testSplit() throws IOException {
|
||||
generateHLogs(-1);
|
||||
fs.initialize(fs.getUri(), conf);
|
||||
|
|
@ -704,7 +704,7 @@ public class TestHLogSplit {
|
|||
}
|
||||
}
|
||||
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testLogDirectoryShouldBeDeletedAfterSuccessfulSplit()
|
||||
throws IOException {
|
||||
generateHLogs(-1);
|
||||
|
|
@ -722,7 +722,7 @@ public class TestHLogSplit {
|
|||
}
|
||||
}
|
||||
|
||||
@Test(expected = IOException.class)
|
||||
@Test(timeout=300000, expected = IOException.class)
|
||||
public void testSplitWillFailIfWritingToRegionFails() throws Exception {
|
||||
//leave 5th log open so we could append the "trap"
|
||||
HLog.Writer [] writer = generateHLogs(4);
|
||||
|
|
@ -775,7 +775,7 @@ public class TestHLogSplit {
|
|||
assertEquals(0, compareHLogSplitDirs(firstSplitPath, splitPath));
|
||||
}
|
||||
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testSplitDeletedRegion() throws IOException {
|
||||
REGIONS.removeAll(REGIONS);
|
||||
String region = "region_that_splits";
|
||||
|
|
@ -790,7 +790,7 @@ public class TestHLogSplit {
|
|||
assertFalse(fs.exists(regiondir));
|
||||
}
|
||||
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testIOEOnOutputThread() throws Exception {
|
||||
conf.setBoolean(HBASE_SKIP_ERRORS, false);
|
||||
|
||||
|
|
@ -819,7 +819,7 @@ public class TestHLogSplit {
|
|||
}
|
||||
|
||||
// Test for HBASE-3412
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testMovedHLogDuringRecovery() throws Exception {
|
||||
generateHLogs(-1);
|
||||
|
||||
|
|
@ -842,7 +842,7 @@ public class TestHLogSplit {
|
|||
}
|
||||
}
|
||||
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testRetryOpenDuringRecovery() throws Exception {
|
||||
generateHLogs(-1);
|
||||
|
||||
|
|
@ -881,7 +881,7 @@ public class TestHLogSplit {
|
|||
}
|
||||
}
|
||||
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testTerminationAskedByReporter() throws IOException, CorruptedLogFileException {
|
||||
generateHLogs(1, 10, -1);
|
||||
FileStatus logfile = fs.listStatus(HLOGDIR)[0];
|
||||
|
|
@ -924,7 +924,7 @@ public class TestHLogSplit {
|
|||
* Test log split process with fake data and lots of edits to trigger threading
|
||||
* issues.
|
||||
*/
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testThreading() throws Exception {
|
||||
doTestThreading(20000, 128*1024*1024, 0);
|
||||
}
|
||||
|
|
@ -933,7 +933,7 @@ public class TestHLogSplit {
|
|||
* Test blocking behavior of the log split process if writers are writing slower
|
||||
* than the reader is reading.
|
||||
*/
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testThreadingSlowWriterSmallBuffer() throws Exception {
|
||||
doTestThreading(200, 1024, 50);
|
||||
}
|
||||
|
|
@ -1042,7 +1042,7 @@ public class TestHLogSplit {
|
|||
// HBASE-2312: tests the case where a RegionServer enters a GC pause,
|
||||
// comes back online after the master declared it dead and started to split.
|
||||
// Want log rolling after a master split to fail
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
@Ignore("Need HADOOP-6886, HADOOP-6840, & HDFS-617 for this. HDFS 0.20.205.1+ should have this")
|
||||
public void testLogRollAfterSplitStart() throws IOException {
|
||||
// set flush interval to a large number so it doesn't interrupt us
|
||||
|
|
@ -1152,7 +1152,7 @@ public class TestHLogSplit {
|
|||
}
|
||||
}
|
||||
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testSplitLogFileWithOneRegion() throws IOException {
|
||||
LOG.info("testSplitLogFileWithOneRegion");
|
||||
final String REGION = "region__1";
|
||||
|
|
@ -1170,7 +1170,7 @@ public class TestHLogSplit {
|
|||
assertEquals(true, logsAreEqual(originalLog, splitLog[0]));
|
||||
}
|
||||
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testSplitLogFileDeletedRegionDir() throws IOException {
|
||||
LOG.info("testSplitLogFileDeletedRegionDir");
|
||||
final String REGION = "region__1";
|
||||
|
|
@ -1190,7 +1190,7 @@ public class TestHLogSplit {
|
|||
assertTrue(true);
|
||||
}
|
||||
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testSplitLogFileEmpty() throws IOException {
|
||||
LOG.info("testSplitLogFileEmpty");
|
||||
injectEmptyFile(".empty", true);
|
||||
|
|
@ -1204,7 +1204,7 @@ public class TestHLogSplit {
|
|||
assertEquals(0, countHLog(fs.listStatus(OLDLOGDIR)[0].getPath(), fs, conf));
|
||||
}
|
||||
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testSplitLogFileMultipleRegions() throws IOException {
|
||||
LOG.info("testSplitLogFileMultipleRegions");
|
||||
generateHLogs(1, 10, -1);
|
||||
|
|
@ -1218,7 +1218,7 @@ public class TestHLogSplit {
|
|||
}
|
||||
}
|
||||
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testSplitLogFileFirstLineCorruptionLog()
|
||||
throws IOException {
|
||||
conf.setBoolean(HBASE_SKIP_ERRORS, true);
|
||||
|
|
@ -1240,7 +1240,7 @@ public class TestHLogSplit {
|
|||
* @throws IOException
|
||||
* @see https://issues.apache.org/jira/browse/HBASE-4862
|
||||
*/
|
||||
@Test
|
||||
@Test (timeout=300000)
|
||||
public void testConcurrentSplitLogAndReplayRecoverEdit() throws IOException {
|
||||
LOG.info("testConcurrentSplitLogAndReplayRecoverEdit");
|
||||
// Generate hlogs for our destination region
|
||||
|
|
|
|||
Loading…
Reference in New Issue