hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From st...@apache.org
Subject svn commit: r1201950 - in /hbase/branches/0.92: CHANGES.txt src/main/java/org/apache/hadoop/hbase/regionserver/Store.java
Date Mon, 14 Nov 2011 22:42:51 GMT
Author: stack
Date: Mon Nov 14 22:42:51 2011
New Revision: 1201950

URL: http://svn.apache.org/viewvc?rev=1201950&view=rev
Log:
HBASE-4778 Don't ignore corrupt StoreFiles when opening a region

Modified:
    hbase/branches/0.92/CHANGES.txt
    hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/regionserver/Store.java

Modified: hbase/branches/0.92/CHANGES.txt
URL: http://svn.apache.org/viewvc/hbase/branches/0.92/CHANGES.txt?rev=1201950&r1=1201949&r2=1201950&view=diff
==============================================================================
--- hbase/branches/0.92/CHANGES.txt (original)
+++ hbase/branches/0.92/CHANGES.txt Mon Nov 14 22:42:51 2011
@@ -435,6 +435,7 @@ Release 0.92.0 - Unreleased
                TestHCM.testConnectionUniqueness (Jinchao)
    HBASE-4690  Intermittent TestRegionServerCoprocessorExceptionWithAbort failure
    HBASE-4518  TestServerCustomProtocol fails intermittently
+   HBASE-4778  Don't ignore corrupt StoreFiles when opening a region
 
   IMPROVEMENTS
    HBASE-3290  Max Compaction Size (Nicolas Spiegelberg via Stack)  

Modified: hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/regionserver/Store.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/regionserver/Store.java?rev=1201950&r1=1201949&r2=1201950&view=diff
==============================================================================
--- hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/regionserver/Store.java (original)
+++ hbase/branches/0.92/src/main/java/org/apache/hadoop/hbase/regionserver/Store.java Mon
Nov 14 22:42:51 2011
@@ -267,17 +267,9 @@ public class Store implements HeapSize {
         LOG.warn("Skipping " + p + " because its empty. HBASE-646 DATA LOSS?");
         continue;
       }
-      StoreFile curfile = null;
-      try {
-        curfile = new StoreFile(fs, p, this.conf, this.cacheConf,
-            this.family.getBloomFilterType());
-        curfile.createReader();
-      } catch (IOException ioe) {
-        LOG.warn("Failed open of " + p + "; presumption is that file was " +
-          "corrupted at flush and lost edits picked up by commit log replay. " +
-          "Verify!", ioe);
-        continue;
-      }
+      StoreFile curfile = new StoreFile(fs, p, this.conf, this.cacheConf,
+          this.family.getBloomFilterType());
+      curfile.createReader();
       long length = curfile.getReader().length();
       this.storeSize += length;
       this.totalUncompressedBytes += curfile.getReader().getTotalUncompressedBytes();



Mime
View raw message