svn commit: r1387725 - /hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/Store.java

[st...@apache.org]

Author: stack
Date: Wed Sep 19 19:48:30 2012
New Revision: 1387725

URL: http://svn.apache.org/viewvc?rev=1387725&view=rev
Log:
HBASE-3834 Store ignores checksum errors when opening files

Modified:
    hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/Store.java

Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/Store.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/Store.java?rev=1387725&r1=1387724&r2=1387725&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/Store.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/regionserver/Store.java Wed Sep 19 19:48:30 2012
@@ -266,17 +266,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, blockcache, this.conf,
+      StoreFile curfile = new StoreFile(fs, p, blockcache, this.conf,
             this.family.getBloomFilterType(), this.inMemory);
-        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;
-      }
+      curfile.createReader();
       long length = curfile.getReader().length();
       this.storeSize += length;
       if (LOG.isDebugEnabled()) {