You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by ty...@apache.org on 2015/01/29 22:45:04 UTC
cassandra git commit: Purge internal prepared stmts when tables are
dropped
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 <ed...@gmail.com>
Authored: Thu Jan 29 15:43:58 2015 -0600
Committer: Tyler Hobbs <ty...@datastax.com>
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);
}