From 4ae05b103690cfb07a8898e04bae6f7b58bd04f4 Mon Sep 17 00:00:00 2001 From: Jonathan Ellis Date: Tue, 1 Sep 2009 23:38:31 +0000 Subject: [PATCH] Do not delete corrupt sstables on startup; skip it and let an operator intervene instead. Patch by Chris Goffinet; reviewed by jbellis for CASSANDRA-343 git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/branches/cassandra-0.4@810311 13f79535-47bb-0310-9956-ffa450edef68 --- src/java/org/apache/cassandra/db/ColumnFamilyStore.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) 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