You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2009/03/06 22:26:27 UTC
svn commit: r751075 - in /hadoop/hbase/branches/0.19: CHANGES.txt
src/java/org/apache/hadoop/hbase/regionserver/HStore.java
Author: stack
Date: Fri Mar 6 21:26:26 2009
New Revision: 751075
URL: http://svn.apache.org/viewvc?rev=751075&view=rev
Log:
HBASE-1243 oldlogfile.dat is screwed, so is it's region
Modified:
hadoop/hbase/branches/0.19/CHANGES.txt
hadoop/hbase/branches/0.19/src/java/org/apache/hadoop/hbase/regionserver/HStore.java
Modified: hadoop/hbase/branches/0.19/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/hbase/branches/0.19/CHANGES.txt?rev=751075&r1=751074&r2=751075&view=diff
==============================================================================
--- hadoop/hbase/branches/0.19/CHANGES.txt (original)
+++ hadoop/hbase/branches/0.19/CHANGES.txt Fri Mar 6 21:26:26 2009
@@ -21,6 +21,7 @@
HBASE-1238 Under upload, region servers are unable
to compact when loaded with hundreds of regions
HBASE-1247 checkAndSave doesn't Write Ahead Log
+ HBASE-1243 oldlogfile.dat is screwed, so is it's region
IMPROVEMENTS
HBASE-845 HCM.isTableEnabled doesn't really tell if it is, or not
Modified: hadoop/hbase/branches/0.19/src/java/org/apache/hadoop/hbase/regionserver/HStore.java
URL: http://svn.apache.org/viewvc/hadoop/hbase/branches/0.19/src/java/org/apache/hadoop/hbase/regionserver/HStore.java?rev=751075&r1=751074&r2=751075&view=diff
==============================================================================
--- hadoop/hbase/branches/0.19/src/java/org/apache/hadoop/hbase/regionserver/HStore.java (original)
+++ hadoop/hbase/branches/0.19/src/java/org/apache/hadoop/hbase/regionserver/HStore.java Fri Mar 6 21:26:26 2009
@@ -339,8 +339,14 @@
TreeMap<HStoreKey, byte []> reconstructedCache =
new TreeMap<HStoreKey, byte []>(new HStoreKey.HStoreKeyWritableComparator(this.info));
- SequenceFile.Reader logReader = new SequenceFile.Reader(this.fs,
- reconstructionLog, this.conf);
+ SequenceFile.Reader logReader = null;
+ try {
+ logReader = new SequenceFile.Reader(this.fs, reconstructionLog, this.conf);
+ } catch (IOException e) {
+ LOG.warn("Failed opening reconstruction log though check for null-size passed. " +
+ "POSSIBLE DATA LOSS!! Soldiering on", e);
+ return;
+ }
try {
HLogKey key = new HLogKey();