diff --git a/src/java/org/apache/cassandra/db/ColumnFamilyStore.java b/src/java/org/apache/cassandra/db/ColumnFamilyStore.java index 46a5ca1455..c53ce0651d 100644 --- a/src/java/org/apache/cassandra/db/ColumnFamilyStore.java +++ b/src/java/org/apache/cassandra/db/ColumnFamilyStore.java @@ -462,7 +462,10 @@ public class ColumnFamilyStore implements ColumnFamilyStoreMBean Set components = sstableFiles.getValue(); if (components.contains(Component.COMPACTED_MARKER) || desc.temporary) + { SSTable.delete(desc, components); + continue; + } File dataFile = new File(desc.filenameFor(Component.DATA)); if (components.contains(Component.DATA) && dataFile.length() > 0)