fix ClassCastException for #6462
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/5d24c553 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/5d24c553 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/5d24c553 Branch: refs/heads/trunk Commit: 5d24c55335e91fde5470ce94306fde26272e2b44 Parents: 2ccb3da Author: Jonathan Ellis <jbel...@apache.org> Authored: Tue Dec 10 10:31:18 2013 +0600 Committer: Jonathan Ellis <jbel...@apache.org> Committed: Tue Dec 10 10:31:18 2013 +0600 ---------------------------------------------------------------------- .../org/apache/cassandra/db/compaction/CompactionManager.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/5d24c553/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 310ddfb..168ee02 100644 --- a/src/java/org/apache/cassandra/db/compaction/CompactionManager.java +++ b/src/java/org/apache/cassandra/db/compaction/CompactionManager.java @@ -560,7 +560,7 @@ public class CompactionManager implements CompactionManagerMBean throw new IOException("disk full"); ICompactionScanner scanner = cleanupStrategy.getScanner(sstable, getRateLimiter()); - CleanupInfo ci = new CleanupInfo(sstable, (SSTableScanner)scanner); + CleanupInfo ci = new CleanupInfo(sstable, scanner); metrics.beginCompaction(ci); SSTableWriter writer = createWriter(cfs, @@ -1052,9 +1052,9 @@ public class CompactionManager implements CompactionManagerMBean private static class CleanupInfo extends CompactionInfo.Holder { private final SSTableReader sstable; - private final SSTableScanner scanner; + private final ICompactionScanner scanner; - public CleanupInfo(SSTableReader sstable, SSTableScanner scanner) + public CleanupInfo(SSTableReader sstable, ICompactionScanner scanner) { this.sstable = sstable; this.scanner = scanner;