Add logging around cassandra snapshot and flushing (#480)

Co-authored-by: Nimai Agarwal <[email protected]>
palantir · Apr 5, 2024 · 053cfd9 · 053cfd9
1 parent eab6db4
commit 053cfd9
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/src/java/org/apache/cassandra/db/ColumnFamilyStore.java b/src/java/org/apache/cassandra/db/ColumnFamilyStore.java
@@ -1112,6 +1112,7 @@ public ReplayPosition call()
 
     public ReplayPosition forceBlockingFlush(String reason)
     {
+        logger.debug("Flushing memtables on cf {} due to {}", name, reason);
         return FBUtilities.waitOnFuture(forceFlush(reason));
     }
 
@@ -2663,6 +2664,7 @@ public void snapshotWithoutFlush(String snapshotName)
      */
     public Set<SSTableReader> snapshotWithoutFlush(String snapshotName, Predicate<SSTableReader> predicate, boolean ephemeral)
     {
+        logger.debug("Taking snapshot without flush for {}", name);
         Set<SSTableReader> snapshottedSSTables = new HashSet<>();
         final JSONArray filesJSONArr = new JSONArray();
         for (ColumnFamilyStore cfs : concatWithIndexes())

diff --git a/src/java/org/apache/cassandra/db/Keyspace.java b/src/java/org/apache/cassandra/db/Keyspace.java
@@ -217,8 +217,10 @@ public void snapshot(String snapshotName, String columnFamilyName, boolean ephem
         {
             if (columnFamilyName == null || cfStore.name.equals(columnFamilyName))
             {
+                logger.debug("Attempting snapshot with snapshotName {} of cf {}", snapshotName, columnFamilyName);
                 tookSnapShot = true;
                 cfStore.snapshot(snapshotName, null, ephemeral);
+                logger.debug("Finished snapshot with snapshotName {} of cf {}", snapshotName, columnFamilyName);
             }
         }