diff --git a/src/java/org/apache/cassandra/db/ColumnFamilyStore.java b/src/java/org/apache/cassandra/db/ColumnFamilyStore.java index af6e247ada..200b304605 100644 --- a/src/java/org/apache/cassandra/db/ColumnFamilyStore.java +++ b/src/java/org/apache/cassandra/db/ColumnFamilyStore.java @@ -175,16 +175,17 @@ public final class ColumnFamilyStore implements ColumnFamilyStoreMBean for (File file : sstableFiles) { String filename = file.getAbsolutePath(); + SSTableReader sstable; try { - SSTableReader sstable = SSTableReader.open(filename); - ssTables_.put(filename, sstable); + sstable = SSTableReader.open(filename); } catch (IOException ex) { - logger_.error("Corrupt file " + filename, ex); - FileUtils.delete(filename); + logger_.error("Corrupt file " + filename + "; skipped", ex); + continue; } + ssTables_.put(filename, sstable); } // submit initial check-for-compaction request