Github user bdeggleston commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/224#discussion_r189039085
--- Diff: src/java/org/apache/cassandra/db/view/ViewBuilder.java ---
@@ -135,14 +137,15 @@ private synchronized void build()
}
// Get the local ranges for which the view hasn't already been
built nor it's building
- Set<Range<Token>> newRanges =
StorageService.instance.getLocalRanges(ksName)
- .stream()
- .map(r ->
r.subtractAll(builtRanges))
-
.flatMap(Set::stream)
- .map(r ->
r.subtractAll(pendingRanges.keySet()))
-
.flatMap(Set::stream)
-
.collect(Collectors.toSet());
-
+ ReplicaSet replicatedRanges =
StorageService.instance.getLocalReplicas(ksName);
+
Replicas.checkFull(StorageService.instance.getLocalReplicas(ksName));
+ Set<Range<Token>> newRanges = replicatedRanges.asRangeSet()
--- End diff --
fixed
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
