diff --git a/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLogSplitter.java b/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLogSplitter.java index 550f759..f6140c5 100644 --- a/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLogSplitter.java +++ b/src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLogSplitter.java @@ -275,8 +275,11 @@ public class HLogSplitter { } catch (IOException e) { // If the IOE resulted from bad file format, // then this problem is idempotent and retrying won't help - if (e.getCause() instanceof ParseException) { - LOG.warn("ParseException from hlog " + logPath + ". continuing"); + if (e.getCause() != null && + (e.getCause() instanceof ParseException || + e.getCause() instanceof org.apache.hadoop.fs.ChecksumException)) { + LOG.warn("Parse exception " + e.getCause().toString() + + " from hlog " + logPath + ". continuing"); processedLogs.add(logPath); } else { if (skipErrors) {