Github user aweisberg commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/224#discussion_r187475433
--- Diff:
src/java/org/apache/cassandra/db/compaction/CompactionManager.java ---
@@ -468,7 +465,7 @@ public AllSSTableOpStatus performCleanup(final
ColumnFamilyStore cfStore, int jo
return AllSSTableOpStatus.ABORTED;
}
// if local ranges is empty, it means no data should remain
- final Collection<Range<Token>> ranges =
StorageService.instance.getLocalRanges(keyspace.getName());
+ final Collection<Range<Token>> ranges =
StorageService.instance.getLocalReplicas(keyspace.getName()).asRangeSet();
--- End diff --
This could use a Collection2.transform version. It's just iterated.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
