Prevent new nodes from thinking down nodes are up forever. Patch by brandonwilliams, reviewed by Peter Schuller for CASSANDRA-3626
git-svn-id: https://svn.apache.org/repos/asf/cassandra/branches/cassandra-0.8@1214916 13f79535-47bb-0310-9956-ffa450edef68 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/0860058e Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/0860058e Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/0860058e Branch: refs/heads/trunk Commit: 0860058edaa8c07dc9bf627601e5580132a00110 Parents: 1f92277 Author: Brandon Williams <brandonwilli...@apache.org> Authored: Thu Dec 15 19:10:36 2011 +0000 Committer: Brandon Williams <brandonwilli...@apache.org> Committed: Thu Dec 15 19:10:36 2011 +0000 ---------------------------------------------------------------------- CHANGES.txt | 3 +++ src/java/org/apache/cassandra/gms/Gossiper.java | 3 ++- 2 files changed, 5 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/0860058e/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index ad24ad6..803e716 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,3 +1,6 @@ +0.8.10 + * prevent new nodes from thinking down nodes are up forever (CASSANDRA-3626) + 0.8.9 * remove invalid assertion that table was opened before dropping it (CASSANDRA-3580) http://git-wip-us.apache.org/repos/asf/cassandra/blob/0860058e/src/java/org/apache/cassandra/gms/Gossiper.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/gms/Gossiper.java b/src/java/org/apache/cassandra/gms/Gossiper.java index 343d7e9..0f47259 100644 --- a/src/java/org/apache/cassandra/gms/Gossiper.java +++ b/src/java/org/apache/cassandra/gms/Gossiper.java @@ -831,7 +831,8 @@ public class Gossiper implements IFailureDetectionEventListener } else { - // this is a new node + // this is a new node, report it to the FD in case it is the first time we are seeing it AND it's not alive + FailureDetector.instance.report(ep); handleMajorStateChange(ep, remoteState); } }