Github user aweisberg commented on a diff in the pull request: https://github.com/apache/cassandra/pull/269#discussion_r219271571 --- Diff: src/java/org/apache/cassandra/dht/RangeStreamer.java --- @@ -265,10 +318,11 @@ public void addRanges(String keyspaceName, ReplicaCollection<?> replicas) workMap = getOptimizedWorkMap(fetchMap, sourceFilters, keyspaceName); } - toFetch.put(keyspaceName, workMap); - for (Map.Entry<InetAddressAndPort, Collection<FetchReplica>> entry : workMap.asMap().entrySet()) + assert toFetch.put(keyspaceName, workMap) == null : "Keyspace is already added to fetch map"; --- End diff -- If asserts are disabled this doesn't work :-P
--- --------------------------------------------------------------------- To unsubscribe, e-mail: pr-unsubscr...@cassandra.apache.org For additional commands, e-mail: pr-h...@cassandra.apache.org