Log(info) schema changes patch by Pavel Yaskevich; reviewed by Brandon Williams for CASSANDRA-4547
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/f5619bbf Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/f5619bbf Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/f5619bbf Branch: refs/heads/trunk Commit: f5619bbfdc7e17e33fc27c9e2d06293cde14c800 Parents: a343c85 Author: Pavel Yaskevich <xe...@apache.org> Authored: Fri Aug 17 12:32:57 2012 +0300 Committer: Pavel Yaskevich <xe...@apache.org> Committed: Fri Aug 17 19:21:43 2012 +0300 ---------------------------------------------------------------------- CHANGES.txt | 4 ++++ .../apache/cassandra/service/MigrationManager.java | 6 ++++++ 2 files changed, 10 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/f5619bbf/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index dfb77d6..2ea901f 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,3 +1,7 @@ +1.1.5 + * Log(info) schema changes (CASSANDRA-4547) + + 1.1.4 * fix offline scrub to catch >= out of order rows (CASSANDRA-4411) * fix cassandra-env.sh on RHEL and other non-dash-based systems http://git-wip-us.apache.org/repos/asf/cassandra/blob/f5619bbf/src/java/org/apache/cassandra/service/MigrationManager.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/service/MigrationManager.java b/src/java/org/apache/cassandra/service/MigrationManager.java index eedb20d..1d4401a 100644 --- a/src/java/org/apache/cassandra/service/MigrationManager.java +++ b/src/java/org/apache/cassandra/service/MigrationManager.java @@ -123,6 +123,7 @@ public class MigrationManager implements IEndpointStateChangeSubscriber if (Schema.instance.getTableDefinition(ksm.name) != null) throw new ConfigurationException(String.format("Cannot add already existing keyspace '%s'.", ksm.name)); + logger.info(String.format("Create new Keyspace: %s", ksm)); announce(ksm.toSchema(FBUtilities.timestampMicros())); } @@ -136,6 +137,7 @@ public class MigrationManager implements IEndpointStateChangeSubscriber else if (ksm.cfMetaData().containsKey(cfm.cfName)) throw new ConfigurationException(String.format("Cannot add already existing column family '%s' to keyspace '%s'.", cfm.cfName, cfm.ksName)); + logger.info(String.format("Create new ColumnFamily: %s", cfm)); announce(cfm.toSchema(FBUtilities.timestampMicros())); } @@ -147,6 +149,7 @@ public class MigrationManager implements IEndpointStateChangeSubscriber if (oldKsm == null) throw new ConfigurationException(String.format("Cannot update non existing keyspace '%s'.", ksm.name)); + logger.info(String.format("Update Keyspace '%s' From %s To %s", ksm.name, oldKsm, ksm)); announce(oldKsm.toSchemaUpdate(ksm, FBUtilities.timestampMicros())); } @@ -158,6 +161,7 @@ public class MigrationManager implements IEndpointStateChangeSubscriber if (oldCfm == null) throw new ConfigurationException(String.format("Cannot update non existing column family '%s' in keyspace '%s'.", cfm.cfName, cfm.ksName)); + logger.info(String.format("Update ColumnFamily '%s/%s' From %s To %s", cfm.ksName, cfm.cfName, oldCfm, cfm)); announce(oldCfm.toSchemaUpdate(cfm, FBUtilities.timestampMicros())); } @@ -167,6 +171,7 @@ public class MigrationManager implements IEndpointStateChangeSubscriber if (oldKsm == null) throw new ConfigurationException(String.format("Cannot drop non existing keyspace '%s'.", ksName)); + logger.info(String.format("Drop Keyspace '%s'", oldKsm.name)); announce(oldKsm.dropFromSchema(FBUtilities.timestampMicros())); } @@ -176,6 +181,7 @@ public class MigrationManager implements IEndpointStateChangeSubscriber if (oldCfm == null) throw new ConfigurationException(String.format("Cannot drop non existing column family '%s' in keyspace '%s'.", cfName, ksName)); + logger.info(String.format("Drop ColumnFamily '%s/%s'", oldCfm.ksName, oldCfm.cfName)); announce(oldCfm.dropFromSchema(FBUtilities.timestampMicros())); }
