Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-3674 Treat ChecksumException as we would a ParseException splitting logs; else we replay split on every restart 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1084051 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Michael Stack 2011-03-22 02:04:01 +00:00
parent d2ccdeb8dd
commit 53a031f00c
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
CHANGES.txt
View File

@ -153,6 +153,8 @@ Release 0.90.2 - Unreleased
HBASE-3664 [replication] Adding a slave when there's none may kill the cluster HBASE-3664 [replication] Adding a slave when there's none may kill the cluster
HBASE-3671 Split report before we finish parent region open; workaround HBASE-3671 Split report before we finish parent region open; workaround
till 0.92; Race between split and OPENED processing till 0.92; Race between split and OPENED processing
HBASE-3674 Treat ChecksumException as we would a ParseException splitting
logs; else we replay split on every restart
IMPROVEMENTS IMPROVEMENTS
HBASE-3542 MultiGet methods in Thrift HBASE-3542 MultiGet methods in Thrift

4
src/main/java/org/apache/hadoop/hbase/regionserver/wal/HLogSplitter.java
View File

@ -243,7 +243,7 @@ public class HLogSplitter {
List<Path> corruptedLogs = new ArrayList<Path>(); List<Path> corruptedLogs = new ArrayList<Path>();
List<Path> splits = null; List<Path> splits = null;
boolean skipErrors = conf.getBoolean("hbase.hlog.split.skip.errors", false); boolean skipErrors = conf.getBoolean("hbase.hlog.split.skip.errors", true);
splitSize = 0; splitSize = 0;
@ -276,7 +276,7 @@ public class HLogSplitter {
// If the IOE resulted from bad file format, // If the IOE resulted from bad file format,
// then this problem is idempotent and retrying won't help // then this problem is idempotent and retrying won't help
if (e.getCause() instanceof ParseException) { if (e.getCause() instanceof ParseException) {
LOG.warn("ParseException from hlog " + logPath + ". continuing"); LOG.warn("Parse exception from hlog " + logPath + ". continuing", e);
processedLogs.add(logPath); processedLogs.add(logPath);
} else { } else {
if (skipErrors) { if (skipErrors) {