Github user aweisberg commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r219277526
--- Diff: src/java/org/apache/cassandra/dht/RangeStreamer.java ---
@@ -436,6 +436,7 @@ else if (useStrictConsistency)
Set<InetAddressAndPort> endpointsStillReplicated
= newEndpoints.endpoints();
// Remove new endpoints from old endpoints based
on address
oldEndpoints = oldEndpoints.filter(r ->
!endpointsStillReplicated.contains(r.endpoint()));
+ oldEndpoints.filter(testSourceFilters);
--- End diff --
Uh, this doesn't store the result and the tests all still pass so it wasn't
doing anything anyways?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
