From 9153a57a07590c6ef421a5e787da76aa82997ef4 Mon Sep 17 00:00:00 2001 From: Will Dey Date: Wed, 23 Oct 2024 21:12:49 -0400 Subject: [PATCH] comment --- .../com/palantir/cassandra/db/ColumnFamilyStoreManager.java | 1 - src/java/org/apache/cassandra/db/compaction/CompactionTask.java | 1 - src/java/org/apache/cassandra/service/CassandraDaemon.java | 2 +- 3 files changed, 1 insertion(+), 3 deletions(-) diff --git a/src/java/com/palantir/cassandra/db/ColumnFamilyStoreManager.java b/src/java/com/palantir/cassandra/db/ColumnFamilyStoreManager.java index d637624f24..86669cbed0 100644 --- a/src/java/com/palantir/cassandra/db/ColumnFamilyStoreManager.java +++ b/src/java/com/palantir/cassandra/db/ColumnFamilyStoreManager.java @@ -25,7 +25,6 @@ import com.palantir.cassandra.db.compaction.IColumnFamilyStoreWriteAheadLogger; import org.apache.cassandra.config.CFMetaData; import org.apache.cassandra.io.sstable.Descriptor; -import org.apache.cassandra.utils.Pair; public class ColumnFamilyStoreManager implements IColumnFamilyStoreValidator, IColumnFamilyStoreWriteAheadLogger diff --git a/src/java/org/apache/cassandra/db/compaction/CompactionTask.java b/src/java/org/apache/cassandra/db/compaction/CompactionTask.java index fa310f5440..c13aa0c737 100644 --- a/src/java/org/apache/cassandra/db/compaction/CompactionTask.java +++ b/src/java/org/apache/cassandra/db/compaction/CompactionTask.java @@ -25,7 +25,6 @@ import java.util.UUID; import java.util.concurrent.TimeUnit; import java.util.function.BiFunction; -import java.util.stream.Collectors; import com.google.common.base.Predicate; import com.google.common.collect.Iterables; diff --git a/src/java/org/apache/cassandra/service/CassandraDaemon.java b/src/java/org/apache/cassandra/service/CassandraDaemon.java index cfd311e065..529e6ef1fb 100644 --- a/src/java/org/apache/cassandra/service/CassandraDaemon.java +++ b/src/java/org/apache/cassandra/service/CassandraDaemon.java @@ -291,7 +291,7 @@ private void completeSetupMayThrowSstableException() { for (CFMetaData cfm : Schema.instance.getKeyspaceMetaData(keyspaceName).values()) { - if (ColumnFamilyStoreManager.instance.shouldRemoveUnusedSstables()) { + if (ColumnFamilyStoreManager.instance.shouldRemoveUnusedSstablesBasedOnAncestorMetadata()) { ColumnFamilyStore.removeUnusedSstables(cfm, unfinishedCompactions.getOrDefault(cfm.ksAndCFName, ImmutableMap.of())); } ColumnFamilyStore.scrubDataDirectories(cfm);