diff --git a/src/java/org/apache/cassandra/gms/GossipDigestAck2VerbHandler.java b/src/java/org/apache/cassandra/gms/GossipDigestAck2VerbHandler.java index 3fb925533c..92b84633df 100644 --- a/src/java/org/apache/cassandra/gms/GossipDigestAck2VerbHandler.java +++ b/src/java/org/apache/cassandra/gms/GossipDigestAck2VerbHandler.java @@ -37,6 +37,13 @@ public class GossipDigestAck2VerbHandler implements IVerbHandler remoteEpStateMap = message.payload.getEndpointStateMap(); /* Notify the Failure Detector */ Gossiper.instance.notifyFailureDetector(remoteEpStateMap); diff --git a/src/java/org/apache/cassandra/gms/Gossiper.java b/src/java/org/apache/cassandra/gms/Gossiper.java index c9d0d512a8..60ca850c45 100644 --- a/src/java/org/apache/cassandra/gms/Gossiper.java +++ b/src/java/org/apache/cassandra/gms/Gossiper.java @@ -1077,7 +1077,7 @@ public class Gossiper implements IFailureDetectionEventListener, GossiperMBean logger.info("Announcing shutdown"); try { - Thread.sleep(intervalInMillis); + Thread.sleep(intervalInMillis * 2); } catch (InterruptedException e) {