Index: src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLogSplitter.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLogSplitter.java (revision 1101351) +++ src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLogSplitter.java (working copy) @@ -412,10 +412,14 @@ wap = createWAP(region, entry, rootDir, tmpname, fs, conf); if (wap == null) { logWriters.put(region, BAD_WRITER); + continue; } else { logWriters.put(region, wap); } } + if (wap == null) { + continue; + } wap.w.append(entry); editsCount++; if (editsCount % interval == 0) { Index: src/main/java/org/apache/hadoop/hbase/regionserver/SplitLogWorker.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/regionserver/SplitLogWorker.java (revision 1101351) +++ src/main/java/org/apache/hadoop/hbase/regionserver/SplitLogWorker.java (working copy) @@ -297,6 +297,8 @@ } break; } + } catch (Exception e) { + LOG.error("An error occurred.", e); } finally { if (t > 0) { LOG.info("worker " + serverName + " done with task " + path +