diff --git a/src/java/org/apache/cassandra/db/ColumnFamilyStore.java b/src/java/org/apache/cassandra/db/ColumnFamilyStore.java index 084f9f56d8..4df06fcac8 100644 --- a/src/java/org/apache/cassandra/db/ColumnFamilyStore.java +++ b/src/java/org/apache/cassandra/db/ColumnFamilyStore.java @@ -728,20 +728,20 @@ public static void removeUnfinishedCompactionLeftovers(CFMetaData metadata, Map< } } - // remove old sstables from compactions that did complete - for (Map.Entry> sstableFiles : directories.sstableLister().list().entrySet()) - { - Descriptor desc = sstableFiles.getKey(); - if (completedAncestors.contains(desc.generation)) - { - // if any of the ancestors were participating in a compaction, finish that compaction - logger.info("Going to delete leftover compaction ancestor {}", desc); - SSTable.delete(desc, sstableFiles.getValue()); - UUID compactionTaskID = unfinishedCompactions.get(desc.generation); - if (compactionTaskID != null) - SystemKeyspace.finishCompaction(unfinishedCompactions.get(desc.generation)); - } - } + // remove3 old sstables from compactions that did complete +// for (Map.Entry> sstableFiles : directories.sstableLister().list().entrySet()) +// { +// Descriptor desc = sstableFiles.getKey(); +// if (completedAncestors.contains(desc.generation)) +// { +// // if any of the ancestors were participating in a compaction, finish that compaction +// logger.info("Going to delete leftover compaction ancestor {}", desc); +// SSTable.delete(desc, sstableFiles.getValue()); +// UUID compactionTaskID = unfinishedCompactions.get(desc.generation); +// if (compactionTaskID != null) +// SystemKeyspace.finishCompaction(unfinishedCompactions.get(desc.generation)); +// } +// } } /**