Fix streaming from all replica during boostrap/rebuild
patch by scode; reviewed by slebresne for CASSANDRA-3922
diff --git a/CHANGES.txt b/CHANGES.txt
index 613c14e..6786c9d 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -64,7 +64,7 @@
* Allow extending CompositeType comparator (CASSANDRA-3657)
* Avoids over-paging during get_count (CASSANDRA-3798)
* Add new command to rebuild a node without (repair) merkle tree calculations
- (CASSANDRA-3483)
+ (CASSANDRA-3483, 3922)
* respect not only row cache capacity but caching mode when
trying to read data (CASSANDRA-3812)
* fix system tests (CASSANDRA-3827)
diff --git a/src/java/org/apache/cassandra/dht/RangeStreamer.java b/src/java/org/apache/cassandra/dht/RangeStreamer.java
index 9b2b41a..47931f8 100644
--- a/src/java/org/apache/cassandra/dht/RangeStreamer.java
+++ b/src/java/org/apache/cassandra/dht/RangeStreamer.java
@@ -189,6 +189,7 @@
rangeFetchMapMap.put(address, range);
foundSource = true;
+ break; // ensure we only stream from one other node for each range
}
if (!foundSource)