Mailing-List: contact commits-help@hbase.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@hbase.apache.org
Content-Type: text/plain; charset="utf-8"
MIME-Version: 1.0
Content-Transfer-Encoding: 7bit
Subject: svn commit: r1505818 -
 /hbase/branches/0.95/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestHLogSplit.java
Date: Mon, 22 Jul 2013 21:06:17 -0000
To: commits@hbase.apache.org
From: stack@apache.org
Message-Id: <20130722210617.9B87A23888E4@eris.apache.org>

Author: stack
Date: Mon Jul 22 21:06:17 2013
New Revision: 1505818

URL: http://svn.apache.org/r1505818
Log:
HBASE-9018 Add timeouts on all tests in TestHLogSplit

Modified:
    hbase/branches/0.95/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestHLogSplit.java

Modified: hbase/branches/0.95/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestHLogSplit.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.95/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestHLogSplit.java?rev=1505818&r1=1505817&r2=1505818&view=diff
==============================================================================
--- hbase/branches/0.95/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestHLogSplit.java (original)
+++ hbase/branches/0.95/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestHLogSplit.java Mon Jul 22 21:06:17 2013
@@ -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