warn when we won't connect to an older seed
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/649a5cd1 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/649a5cd1 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/649a5cd1 Branch: refs/heads/trunk Commit: 649a5cd12fc1797c03aab3da42a6775e39ad69a3 Parents: 322e8f0 Author: Brandon Williams <brandonwilli...@apache.org> Authored: Thu Feb 26 10:30:26 2015 -0800 Committer: Brandon Williams <brandonwilli...@apache.org> Committed: Thu Feb 26 10:30:26 2015 -0800 ---------------------------------------------------------------------- src/java/org/apache/cassandra/net/OutboundTcpConnection.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/649a5cd1/src/java/org/apache/cassandra/net/OutboundTcpConnection.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/net/OutboundTcpConnection.java b/src/java/org/apache/cassandra/net/OutboundTcpConnection.java index a0ad011..4586667 100644 --- a/src/java/org/apache/cassandra/net/OutboundTcpConnection.java +++ b/src/java/org/apache/cassandra/net/OutboundTcpConnection.java @@ -356,6 +356,8 @@ public class OutboundTcpConnection extends Thread // a different target version (targetVersion < MessagingService.VERSION_12) // or if the same version the handshake will finally succeed logger.debug("Target max version is {}; no version information yet, will retry", maxTargetVersion); + if (DatabaseDescriptor.getSeeds().contains(poolReference.endPoint())) + logger.warn("Seed gossip version is {}; will not connect with that version", maxTargetVersion); disconnect(); continue; }
