Merge branch 'cassandra-3.0' into trunk

This commit is contained in:
Sylvain Lebresne 2015-09-11 18:42:19 +02:00
commit a3c2d142ab
1 changed files with 3 additions and 3 deletions

View File

@ -625,20 +625,20 @@ public class QueryProcessor implements QueryHandler
public void onUpdateColumnFamily(String ksName, String cfName, boolean columnsDidChange)
{
logger.info("Column definitions for {}.{} changed, invalidating related prepared statements", ksName, cfName);
logger.debug("Column definitions for {}.{} changed, invalidating related prepared statements", ksName, cfName);
if (columnsDidChange)
removeInvalidPreparedStatements(ksName, cfName);
}
public void onDropKeyspace(String ksName)
{
logger.info("Keyspace {} was dropped, invalidating related prepared statements", ksName);
logger.debug("Keyspace {} was dropped, invalidating related prepared statements", ksName);
removeInvalidPreparedStatements(ksName, null);
}
public void onDropColumnFamily(String ksName, String cfName)
{
logger.info("Table {}.{} was dropped, invalidating related prepared statements", ksName, cfName);
logger.debug("Table {}.{} was dropped, invalidating related prepared statements", ksName, cfName);
removeInvalidPreparedStatements(ksName, cfName);
}