Index: src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java =================================================================== --- src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java (revision 998497) +++ src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java (working copy) @@ -1763,12 +1763,13 @@ if (seqid > minSeqId) { // Then we added some edits to memory. Flush and cleanup split edit files. internalFlushcache(null, seqid); - for (Path file: files) { - if (!this.fs.delete(file, false)) { - LOG.error("Failed delete of " + file); - } else { - LOG.debug("Deleted recovered.edits file=" + file); - } + } + // Now delete the content of recovered edits. We're done w/ them. + for (Path file: files) { + if (!this.fs.delete(file, false)) { + LOG.error("Failed delete of " + file); + } else { + LOG.debug("Deleted recovered.edits file=" + file); } } return seqid;