Github user jasobrown commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/184#discussion_r163071575
--- Diff: src/java/org/apache/cassandra/gms/Gossiper.java ---
@@ -1207,12 +1239,27 @@ private void applyNewStates(InetAddress addr,
EndpointState localState, Endpoint
assert remoteState.getHeartBeatState().getGeneration() ==
localState.getHeartBeatState().getGeneration();
localState.addApplicationStates(remoteStates);
- for (Entry<ApplicationState, VersionedValue> remoteEntry :
remoteStates)
+ //Filter out pre-4.0 versions of data for more complete 4.0
versions
+ Set<Entry<ApplicationState, VersionedValue>> filtered =
remoteStates.stream().filter(entry -> {
--- End diff --
uggh. nevermind. I am incorrect here. this lambda is for the filter
function, not a "possibly replace old value with new value" function.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
