natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Don't request migrations from 1.2+ nodes

This commit is contained in:
Aleksey Yeschenko 2013-03-14 01:54:00 +03:00
parent ba06e4128b
commit 3346771a03
2 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/java/org/apache/cassandra/net/MessagingService.java
View File

@ -70,6 +70,7 @@ public final class MessagingService implements MessagingServiceMBean
public static final int VERSION_10 = 3;
public static final int VERSION_11 = 4;
public static final int VERSION_117 = 5;
public static final int VERSION_12 = 6;
public static final int version_ = VERSION_117;

4
src/java/org/apache/cassandra/service/MigrationManager.java
View File

@ -110,6 +110,10 @@ public class MigrationManager implements IEndpointStateChangeSubscriber
if (Gossiper.instance.getVersion(endpoint) < MessagingService.VERSION_117)
return;
// Don't request migrations from nodes with versions that are >= 1.2
if (Gossiper.instance.getVersion(endpoint) >= MessagingService.VERSION_12)
return;
if (Schema.instance.getVersion().equals(theirVersion))
return;