Expose StorageService.dropPreparedStatements via JMX

pauloricardomg · pauloricardomg · commit c5d6a36fa790 · 2025-08-29T14:00:03.000-04:00
Patch by Paulo Motta; Reviewed by Dmitry Konstantinov, Jeremiah Jordan for CASSANDRA-20870
diff --git a/CHANGES.txt b/CHANGES.txt
@@ -1,4 +1,5 @@
 5.0.6
+ * Expose StorageService.dropPreparedStatements via JMX (CASSANDRA-20870)
  * Sort SSTable TOC entries for determinism (CASSANDRA-20494)
 Merged from 4.0:
  * Update Jackson to 2.19.2 (CASSANDRA-20848)
diff --git a/src/java/org/apache/cassandra/service/StorageService.java b/src/java/org/apache/cassandra/service/StorageService.java
@@ -4242,6 +4242,7 @@ public List<Pair<String, String>> getPreparedStatements()
         return statements;
     }
 
+    @Override
     public void dropPreparedStatements(boolean memoryOnly)
     {
         QueryProcessor.instance.clearPreparedStatements(memoryOnly);
diff --git a/src/java/org/apache/cassandra/service/StorageServiceMBean.java b/src/java/org/apache/cassandra/service/StorageServiceMBean.java
@@ -1326,4 +1326,6 @@ public void enableAuditLog(String loggerName, String includedKeyspaces, String e
     void setPaxosRepairRaceWait(boolean paxosRepairCoordinatorWait);
 
     boolean getPaxosRepairRaceWait();
+
+    public void dropPreparedStatements(boolean memoryOnly);
 }

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,5 @@`
`1`	`1`	`5.0.6`
	`2`	`+ * Expose StorageService.dropPreparedStatements via JMX (CASSANDRA-20870)`
`2`	`3`	`* Sort SSTable TOC entries for determinism (CASSANDRA-20494)`
`3`	`4`	`Merged from 4.0:`
`4`	`5`	`* Update Jackson to 2.19.2 (CASSANDRA-20848)`
Original file line number	Diff line number	Diff line change
`@@ -4242,6 +4242,7 @@ public List<Pair<String, String>> getPreparedStatements()`
`4242`	`4242`	`return statements;`
`4243`	`4243`	`}`
`4244`	`4244`
	`4245`	`+ @Override`
`4245`	`4246`	`public void dropPreparedStatements(boolean memoryOnly)`
`4246`	`4247`	`{`
`4247`	`4248`	`QueryProcessor.instance.clearPreparedStatements(memoryOnly);`
Original file line number	Diff line number	Diff line change
`@@ -1326,4 +1326,6 @@ public void enableAuditLog(String loggerName, String includedKeyspaces, String e`
`1326`	`1326`	`void setPaxosRepairRaceWait(boolean paxosRepairCoordinatorWait);`
`1327`	`1327`
`1328`	`1328`	`boolean getPaxosRepairRaceWait();`
	`1329`	`+`
	`1330`	`+ public void dropPreparedStatements(boolean memoryOnly);`
`1329`	`1331`	`}`