Github user aweisberg commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/224#discussion_r187476007
--- Diff:
src/java/org/apache/cassandra/db/compaction/CompactionManager.java ---
@@ -871,7 +868,7 @@ public void forceUserDefinedCleanup(String dataFiles)
{
ColumnFamilyStore cfs = entry.getKey();
Keyspace keyspace = cfs.keyspace;
- Collection<Range<Token>> ranges =
StorageService.instance.getLocalRanges(keyspace.getName());
+ Collection<Range<Token>> ranges =
StorageService.instance.getLocalReplicas(keyspace.getName()).asRangeSet();
--- End diff --
Also just iterated
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
