diff --git a/src/java/org/apache/cassandra/db/compaction/CompactionTask.java b/src/java/org/apache/cassandra/db/compaction/CompactionTask.java
index 4ca0e0f53ff5..7de68f33883a 100644
--- a/src/java/org/apache/cassandra/db/compaction/CompactionTask.java
+++ b/src/java/org/apache/cassandra/db/compaction/CompactionTask.java
@@ -134,6 +134,7 @@ protected void runMayThrow() throws Exception
         {
 
             final Set<SSTableReader> fullyExpiredSSTables = controller.getFullyExpiredSSTables();
+            fullyExpiredSSTables.forEach(transaction::obsolete);
 
             TimeUUID taskId = transaction.opId();
             // select SSTables to compact based on available disk space.