You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by br...@apache.org on 2014/02/07 15:38:01 UTC
[3/8] git commit: Fix unwanted schema pull while upgrading nodes from
1.2 to 2.0 Patch by Sergio Bossa,
reviewed by brandonwilliams for CASSANDRA-6678
Fix unwanted schema pull while upgrading nodes from 1.2 to 2.0
Patch by Sergio Bossa, reviewed by brandonwilliams for CASSANDRA-6678
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/31414fb8
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/31414fb8
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/31414fb8
Branch: refs/heads/trunk
Commit: 31414fb871c073a19a02dce5dda70bf3df0e5888
Parents: 8b6d87b
Author: Brandon Williams <br...@apache.org>
Authored: Fri Feb 7 08:34:00 2014 -0600
Committer: Brandon Williams <br...@apache.org>
Committed: Fri Feb 7 08:34:00 2014 -0600
----------------------------------------------------------------------
src/java/org/apache/cassandra/service/MigrationManager.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/31414fb8/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 37d5f43..fd9eeda 100644
--- a/src/java/org/apache/cassandra/service/MigrationManager.java
+++ b/src/java/org/apache/cassandra/service/MigrationManager.java
@@ -138,9 +138,10 @@ public class MigrationManager
* Don't request schema from nodes with a higher major (may have incompatible schema)
* Don't request schema from fat clients
*/
- return MessagingService.instance().getVersion(endpoint) >= MessagingService.VERSION_117
- && MessagingService.instance().getVersion(endpoint) <= MessagingService.current_version
- && !Gossiper.instance.isFatClient(endpoint);
+ return MessagingService.instance().knowsVersion(endpoint)
+ && MessagingService.instance().getVersion(endpoint) >= MessagingService.VERSION_117
+ && MessagingService.instance().getVersion(endpoint) <= MessagingService.current_version
+ && !Gossiper.instance.isFatClient(endpoint);
}
public static boolean isReadyForBootstrap()