fix repair test after CASSANDRA-5523
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/c007102c Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/c007102c Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/c007102c Branch: refs/heads/trunk Commit: c007102c5b2fe2b6abd09a19cbc4b69f5e83ad0b Parents: de98541 Author: Yuki Morishita <yu...@apache.org> Authored: Fri May 3 12:53:16 2013 -0500 Committer: Yuki Morishita <yu...@apache.org> Committed: Fri May 3 12:53:16 2013 -0500 ---------------------------------------------------------------------- .../service/AntiEntropyServiceTestAbstract.java | 3 +++ 1 files changed, 3 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/c007102c/test/unit/org/apache/cassandra/service/AntiEntropyServiceTestAbstract.java ---------------------------------------------------------------------- diff --git a/test/unit/org/apache/cassandra/service/AntiEntropyServiceTestAbstract.java b/test/unit/org/apache/cassandra/service/AntiEntropyServiceTestAbstract.java index 7124ecb..fc0b832 100644 --- a/test/unit/org/apache/cassandra/service/AntiEntropyServiceTestAbstract.java +++ b/test/unit/org/apache/cassandra/service/AntiEntropyServiceTestAbstract.java @@ -43,6 +43,8 @@ import org.apache.cassandra.gms.Gossiper; import org.apache.cassandra.locator.AbstractReplicationStrategy; import org.apache.cassandra.locator.TokenMetadata; import static org.apache.cassandra.service.AntiEntropyService.*; + +import org.apache.cassandra.net.MessagingService; import org.apache.cassandra.utils.ByteBufferUtil; import org.apache.cassandra.utils.FBUtilities; import org.apache.cassandra.utils.MerkleTree; @@ -100,6 +102,7 @@ public abstract class AntiEntropyServiceTestAbstract extends SchemaLoader tmd.updateNormalToken(StorageService.getPartitioner().getMinimumToken(), REMOTE); assert tmd.isMember(REMOTE); + MessagingService.instance().setVersion(REMOTE, MessagingService.current_version); Gossiper.instance.initializeNodeUnsafe(REMOTE, UUID.randomUUID(), 1); local_range = StorageService.instance.getPrimaryRangesForEndpoint(tablename, LOCAL).iterator().next();