Author: jbellis
Date: Mon Nov 15 14:53:34 2010
New Revision: 1035294

URL: http://svn.apache.org/viewvc?rev=1035294&view=rev
Log:
clear endpoint cache after updating keyspace metadata
patch by jbellis; reviewed by gdusbabek for CASSANDRA-1741

Modified:
    cassandra/branches/cassandra-0.7/CHANGES.txt
    
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/migration/UpdateKeyspace.java

Modified: cassandra/branches/cassandra-0.7/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/CHANGES.txt?rev=1035294&r1=1035293&r2=1035294&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.7/CHANGES.txt (original)
+++ cassandra/branches/cassandra-0.7/CHANGES.txt Mon Nov 15 14:53:34 2010
@@ -29,6 +29,7 @@ dev
  * upgrade to ConcurrentLinkedHashMap 1.1 (CASSANDRA-975)
  * fix index scan routing (CASSANDRA-1722)
  * fix tombstoning of supercolumns in range queries (CASSANDRA-1734)
+ * clear endpoint cache after updating keyspace metadata (CASSANDRA-1741)
 
 
 0.7.0-beta3

Modified: 
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/migration/UpdateKeyspace.java
URL: 
http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/migration/UpdateKeyspace.java?rev=1035294&r1=1035293&r2=1035294&view=diff
==============================================================================
--- 
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/migration/UpdateKeyspace.java
 (original)
+++ 
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/migration/UpdateKeyspace.java
 Mon Nov 15 14:53:34 2010
@@ -4,6 +4,7 @@ import org.apache.cassandra.config.CFMet
 import org.apache.cassandra.config.ConfigurationException;
 import org.apache.cassandra.config.DatabaseDescriptor;
 import org.apache.cassandra.config.KSMetaData;
+import org.apache.cassandra.db.Table;
 import org.apache.cassandra.utils.FBUtilities;
 import org.apache.cassandra.utils.UUIDGen;
 
@@ -58,6 +59,7 @@ public class UpdateKeyspace extends Migr
     {
         DatabaseDescriptor.clearTableDefinition(oldKsm, newVersion);
         DatabaseDescriptor.setTableDefinition(newKsm, newVersion);
+        Table.open(newKsm.name).replicationStrategy.clearEndpointCache();
         logger.info("Keyspace updated. Please perform any manual operations.");
     }
 


Reply via email to