Github user aweisberg commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/224#discussion_r187475375
--- Diff:
src/java/org/apache/cassandra/db/compaction/CompactionManager.java ---
@@ -533,7 +530,7 @@ public AllSSTableOpStatus relocateSSTables(final
ColumnFamilyStore cfs, int jobs
logger.info("Partitioner does not support splitting");
return AllSSTableOpStatus.ABORTED;
}
- final Collection<Range<Token>> r =
StorageService.instance.getLocalRanges(cfs.keyspace.getName());
+ final Collection<Range<Token>> r =
StorageService.instance.getLocalReplicas(cfs.keyspace.getName()).asRangeSet();
--- End diff --
This is hardly even used. It just checks for isEmpty(). No need to unwrap.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
