Github user ifesdjeen commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r219488342
--- 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 --
Fixed
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
