Fixup node update for removed nodes
@@ -668,8 +668,11 @@ public class CassandraDiscovery extends AbstractLifecycleComponent implements Di
if (logger.isTraceEnabled())
logger.trace("Endpoint={} ApplicationState={} value={}", endpoint, state, versionValue);
+ VersionedValue vv = epState.getApplicationState(ApplicationState.STATUS);
+ if (vv == null || !"removed".equals(vv.value)) {
gossipCluster.update(endpoint, epState, "onChange-" + endpoint, true);
}
+ }
// self status update.
if (this.localAddress.equals(endpoint)) {
