Repository: cassandra Updated Branches: refs/heads/cassandra-2.0 e70f4f81a -> 87cbcc0fc
Schedule fat client schema pull on join patch by Oleg Anastasyev; reviewed by Aleksey Yeschenko for CASSANDRA-7993 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/87cbcc0f Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/87cbcc0f Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/87cbcc0f Branch: refs/heads/cassandra-2.0 Commit: 87cbcc0fc1d0fc0375332d77b252f4e0d7b95f80 Parents: e70f4f8 Author: Oleg Anastasyev <olega...@gmail.com> Authored: Wed Oct 8 01:20:44 2014 +0300 Committer: Aleksey Yeschenko <alek...@apache.org> Committed: Wed Oct 8 01:20:44 2014 +0300 ---------------------------------------------------------------------- CHANGES.txt | 1 + src/java/org/apache/cassandra/service/StorageService.java | 3 ++- 2 files changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/87cbcc0f/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index 188f951..1bef399 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,4 +1,5 @@ 2.0.11: + * Schedule fat client schema pull on join (CASSANDRA-7993) * Don't reset nodes' versions when closing IncomingTcpConnections (CASSANDRA-7734) * Record the real messaging version in all cases in OutboundTcpConnection http://git-wip-us.apache.org/repos/asf/cassandra/blob/87cbcc0f/src/java/org/apache/cassandra/service/StorageService.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/service/StorageService.java b/src/java/org/apache/cassandra/service/StorageService.java index 43bc198..0cd4be5 100644 --- a/src/java/org/apache/cassandra/service/StorageService.java +++ b/src/java/org/apache/cassandra/service/StorageService.java @@ -1970,6 +1970,8 @@ public class StorageService extends NotificationBroadcasterSupport implements IE public void onAlive(InetAddress endpoint, EndpointState state) { + MigrationManager.instance.scheduleSchemaPull(endpoint, state); + if (isClientMode) return; @@ -1984,7 +1986,6 @@ public class StorageService extends NotificationBroadcasterSupport implements IE for (IEndpointLifecycleSubscriber subscriber : lifecycleSubscribers) subscriber.onJoinCluster(endpoint); } - MigrationManager.instance.scheduleSchemaPull(endpoint, state); } public void onRemove(InetAddress endpoint)
