Github user aweisberg commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/224#discussion_r187476379
--- Diff: src/java/org/apache/cassandra/db/compaction/Verifier.java ---
@@ -209,7 +208,9 @@ public void verify()
markAndThrow();
}
- List<Range<Token>> ownedRanges = isOffline ?
Collections.emptyList() :
Range.normalize(StorageService.instance.getLocalAndPendingRanges(cfs.metadata().keyspace));
+ List<Range<Token>> ownedRanges = isOffline
+ ? Collections.emptyList()
+ :
Range.normalize(StorageService.instance.getLocalAndPendingReplicas(cfs.metadata().keyspace).asRangeSet());
--- End diff --
Another candidate
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
