Add schema_usertypes cleanup to SystemKeyspace#finishStartup()
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/7920ebeb Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/7920ebeb Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/7920ebeb Branch: refs/heads/trunk Commit: 7920ebebe2640ffb59225b7d32d5d818ce76dd12 Parents: 6d2d60a Author: Aleksey Yeschenko <[email protected]> Authored: Fri Nov 7 21:36:40 2014 +0300 Committer: Aleksey Yeschenko <[email protected]> Committed: Fri Nov 7 21:36:40 2014 +0300 ---------------------------------------------------------------------- src/java/org/apache/cassandra/db/SystemKeyspace.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/7920ebeb/src/java/org/apache/cassandra/db/SystemKeyspace.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/db/SystemKeyspace.java b/src/java/org/apache/cassandra/db/SystemKeyspace.java index 02a9530..2a3535a 100644 --- a/src/java/org/apache/cassandra/db/SystemKeyspace.java +++ b/src/java/org/apache/cassandra/db/SystemKeyspace.java @@ -120,7 +120,8 @@ public class SystemKeyspace for (String cfname : Arrays.asList(SystemKeyspace.SCHEMA_KEYSPACES_CF, SystemKeyspace.SCHEMA_COLUMNFAMILIES_CF, SystemKeyspace.SCHEMA_COLUMNS_CF, - SystemKeyspace.SCHEMA_TRIGGERS_CF)) + SystemKeyspace.SCHEMA_TRIGGERS_CF, + SystemKeyspace.SCHEMA_USER_TYPES_CF)) executeOnceInternal(String.format("DELETE FROM system.%s WHERE keyspace_name = ?", cfname), ksmd.name); // (+1 to timestamp to make sure we don't get shadowed by the tombstones we just added)
