natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Invalidate key cache on table drop 

patch by thobbs; reviewed by slebresne for CASSANDRA-6525
This commit is contained in:
Sylvain Lebresne 2014-05-21 11:44:50 +02:00
parent 20e058b2bd
commit ca213ccdc0
2 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
CHANGES.txt
View File

@ -47,6 +47,7 @@
* Proper null handle for IF with map element access (CASSANDRA-7155)
* Improve compaction visibility (CASSANDRA-7242)
* Fix 2ndary index queries with DESC clustering order (CASSANDRA-6950)
* Invalid key cache entries on DROP (CASSANDRA-6525)
Merged from 1.2:
* Add Cloudstack snitch (CASSANDRA-7147)
* Update system.peers correctly when relocating tokens (CASSANDRA-7126)

6
src/java/org/apache/cassandra/db/ColumnFamilyStore.java
View File

@ -37,6 +37,7 @@ import org.cliffc.high_scale_lib.NonBlockingHashMap;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.apache.cassandra.cache.KeyCacheKey;
import org.apache.cassandra.cache.IRowCacheEntry;
import org.apache.cassandra.cache.RowCacheKey;
import org.apache.cassandra.cache.RowCacheSentinel;
@ -339,6 +340,11 @@ public class ColumnFamilyStore implements ColumnFamilyStoreMBean
for (RowCacheKey key : CacheService.instance.rowCache.getKeySet())
if (key.cfId == metadata.cfId)
invalidateCachedRow(key);
String ksname = keyspace.getName();
for (KeyCacheKey key : CacheService.instance.keyCache.getKeySet())
if (key.getPathInfo().left.equals(ksname) && key.getPathInfo().right.equals(name))
CacheService.instance.keyCache.remove(key);
}
/**