commit 04ead8c4a5bf73a6d28e56f2c08efad2f702754e Author: nspiegelberg Date: 12 minutes ago HBASE-4778 Don't ignore corrupt StoreFiles when opening a region diff --git a/src/main/java/org/apache/hadoop/hbase/regionserver/Store.java b/src/main/java/org/apache/hadoop/hbase/regionserver/Store.java index a9fe8be..ad7f634 100644 --- a/src/main/java/org/apache/hadoop/hbase/regionserver/Store.java +++ b/src/main/java/org/apache/hadoop/hbase/regionserver/Store.java @@ -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, 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();