diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLogSplitter.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLogSplitter.java index 7febd69..2fa73a8 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLogSplitter.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLogSplitter.java @@ -607,7 +607,7 @@ public class HLogSplitter { Throwable thrown = this.thrown.get(); if (thrown == null) return; if (thrown instanceof IOException) { - throw (IOException)thrown; + throw new IOException(thrown); } else { throw new RuntimeException(thrown); } @@ -790,7 +790,7 @@ public class HLogSplitter { try { doRun(); } catch (Throwable t) { - LOG.error("Error in log splitting write thread", t); + LOG.error("Exiting thread", t); writerThreadError(t); } } 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..91d78d9 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 @@ -810,6 +810,8 @@ public class TestHLogSplit { return mockWriter; } }; + // Start up background thread that will thread dump if we are stuck here. + Threads.threadDumpingIsAlive(Thread.currentThread()); try { logSplitter.splitLogFile(logfiles[0], null); fail("Didn't throw!");