diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestHLogSplit.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestHLogSplit.java index 15e388a..a0f960a 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestHLogSplit.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/regionserver/wal/TestHLogSplit.java @@ -792,6 +792,7 @@ public class TestHLogSplit { @Test public void testIOEOnOutputThread() throws Exception { + LOG.info("Test testIOEOnOutputThread"); conf.setBoolean(HBASE_SKIP_ERRORS, false); generateHLogs(-1); @@ -799,9 +800,9 @@ public class TestHLogSplit { FileStatus[] logfiles = fs.listStatus(HLOGDIR); assertTrue("There should be some log file", logfiles != null && logfiles.length > 0); + LOG.info("Test testIOEOnOutputThread logfile: " + logfiles[0]); // Set up a splitter that will throw an IOE on the output side - HLogSplitter logSplitter = new HLogSplitter( - conf, HBASEDIR, fs, null, null) { + HLogSplitter logSplitter = new HLogSplitter(conf, HBASEDIR, fs, null, null) { protected HLog.Writer createWriter(FileSystem fs, Path logfile, Configuration conf) throws IOException { HLog.Writer mockWriter = Mockito.mock(HLog.Writer.class); @@ -810,12 +811,14 @@ public class TestHLogSplit { return mockWriter; } }; + try { logSplitter.splitLogFile(logfiles[0], null); fail("Didn't throw!"); } catch (IOException ioe) { assertTrue(ioe.toString().contains("Injected")); } + LOG.info("Test testIOEOnOutputThread done"); } // Test for HBASE-3412