Repository: cassandra Updated Branches: refs/heads/cassandra-2.1 c49f6666e -> 05bbefd50
Purge internal prepared stmts when tables are dropped Patch by Edward Ribeiro; reviewed by Tyler Hobbs for CASSANDRA-8693 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/05bbefd5 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/05bbefd5 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/05bbefd5 Branch: refs/heads/cassandra-2.1 Commit: 05bbefd50b98de2e502e38023c9ea496a7719af3 Parents: c49f666 Author: Edward Ribeiro <[email protected]> Authored: Thu Jan 29 15:43:58 2015 -0600 Committer: Tyler Hobbs <[email protected]> Committed: Thu Jan 29 15:43:58 2015 -0600 ---------------------------------------------------------------------- CHANGES.txt | 2 ++ src/java/org/apache/cassandra/cql3/QueryProcessor.java | 1 + 2 files changed, 3 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/05bbefd5/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index a8f8b87..e3e19cf 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,4 +1,6 @@ 2.1.3 + * Purge internal prepared statements if related tables or + keyspaces are dropped (CASSANDRA-8693) * (cqlsh) Handle unicode BOM at start of files (CASSANDRA-8638) * Stop compactions before exiting offline tools (CASSANDRA-8623) * Update tools/stress/README.txt to match current behaviour (CASSANDRA-7933) http://git-wip-us.apache.org/repos/asf/cassandra/blob/05bbefd5/src/java/org/apache/cassandra/cql3/QueryProcessor.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/cql3/QueryProcessor.java b/src/java/org/apache/cassandra/cql3/QueryProcessor.java index e6e6f7d..3d33713 100644 --- a/src/java/org/apache/cassandra/cql3/QueryProcessor.java +++ b/src/java/org/apache/cassandra/cql3/QueryProcessor.java @@ -563,6 +563,7 @@ public class QueryProcessor implements QueryHandler { private void removeInvalidPreparedStatements(String ksName, String cfName) { + removeInvalidPreparedStatements(internalStatements.values().iterator(), ksName, cfName); removeInvalidPreparedStatements(preparedStatements.values().iterator(), ksName, cfName); removeInvalidPreparedStatements(thriftPreparedStatements.values().iterator(), ksName, cfName); }
