ninja fix to f8912ce â Stop SSTables being lost from compaction strategy after full repairs
patch by Mick Semb Wever; reviewed by Michael Shuler for CASSANDRA-14423 Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/3482370d Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/3482370d Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/3482370d Branch: refs/heads/cassandra-3.11 Commit: 3482370df5672c9337a16a8a52baba53b70a4fe8 Parents: 9ff7824 Author: Mick Semb Wever <m...@apache.org> Authored: Tue Jul 10 10:25:50 2018 +1000 Committer: Mick Semb Wever <m...@apache.org> Committed: Wed Jul 11 10:16:06 2018 +1000 ---------------------------------------------------------------------- .../org/apache/cassandra/db/compaction/CompactionManager.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/3482370d/src/java/org/apache/cassandra/db/compaction/CompactionManager.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/db/compaction/CompactionManager.java b/src/java/org/apache/cassandra/db/compaction/CompactionManager.java index 013fc04..c37049f 100644 --- a/src/java/org/apache/cassandra/db/compaction/CompactionManager.java +++ b/src/java/org/apache/cassandra/db/compaction/CompactionManager.java @@ -27,6 +27,7 @@ import javax.management.ObjectName; import javax.management.openmbean.OpenDataException; import javax.management.openmbean.TabularData; +import org.apache.commons.lang3.StringUtils; import com.google.common.annotations.VisibleForTesting; import com.google.common.base.Predicate; import com.google.common.base.Predicates; @@ -581,7 +582,7 @@ public class CompactionManager implements CompactionManagerMBean } if (!anticompactRanges.isEmpty()) - logger.info("SSTable {} ({}) will be anticompacted on ranges: {}", sstable, sstableBounds, String.join(", ", anticompactRanges)); + logger.info("SSTable {} ({}) will be anticompacted on ranges: {}", sstable, sstableBounds, StringUtils.join(anticompactRanges, ", ")); if (!shouldAnticompact) { --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org
