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: [email protected]
For additional commands, e-mail: [email protected]
