delete stats before rename in case of crash

palantir · Sep 5, 2024 · f3ac913 · f3ac913
1 parent c473f24
commit f3ac913
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/java/org/apache/cassandra/db/ColumnFamilyStore.java b/src/java/org/apache/cassandra/db/ColumnFamilyStore.java
@@ -886,12 +886,12 @@ public synchronized int loadNewSSTablesWithCount(boolean assumeCfIsEmpty)
                 }
                 while (new File(newDescriptor.filenameFor(Component.DATA)).exists());
 
-                logger.info("Renaming new SSTable {} to {}", descriptor, newDescriptor);
-                SSTableWriter.rename(descriptor, newDescriptor, components);
-
                 logger.info("Removing Statistics.db for new SSTable {} to clear old ancestor metadata", newDescriptor);
                 FileUtils.delete(new File(newDescriptor.filenameFor(Component.STATS)));
                 components = Sets.difference(components, ImmutableSet.of(Component.STATS));
+
+                logger.info("Renaming new SSTable {} to {}", descriptor, newDescriptor);
+                SSTableWriter.rename(descriptor, newDescriptor, components);
             }
 
             SSTableReader reader;