Updated Branches: refs/heads/trunk ae77ecbaa -> f725ed139
fix tracing relevant cells Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/f725ed13 Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/f725ed13 Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/f725ed13 Branch: refs/heads/trunk Commit: f725ed1390f0a9eb049b0c7c4761073e9a55f124 Parents: c1d1ab7 Author: Jonathan Ellis <[email protected]> Authored: Fri Nov 2 19:32:29 2012 -0500 Committer: Jonathan Ellis <[email protected]> Committed: Fri Nov 2 19:33:09 2012 -0500 ---------------------------------------------------------------------- .../cassandra/db/filter/SliceQueryFilter.java | 5 ++--- 1 files changed, 2 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cassandra/blob/f725ed13/src/java/org/apache/cassandra/db/filter/SliceQueryFilter.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/cassandra/db/filter/SliceQueryFilter.java b/src/java/org/apache/cassandra/db/filter/SliceQueryFilter.java index 75b881b..7d90302 100644 --- a/src/java/org/apache/cassandra/db/filter/SliceQueryFilter.java +++ b/src/java/org/apache/cassandra/db/filter/SliceQueryFilter.java @@ -153,15 +153,14 @@ public class SliceQueryFilter implements IDiskAtomFilter columnCounter.count(column, container); if (columnCounter.live() > count) - { - logger.debug("Read %s live columns and %s tombstoned", columnCounter.live(), columnCounter.ignored()); break; - } // but we need to add all non-gc-able columns to the result for read repair: if (QueryFilter.isRelevant(column, container, gcBefore)) container.addColumn(column); } + + logger.debug("Read {} live cells and {} tombstoned", columnCounter.live(), columnCounter.ignored()); } public int getLiveCount(ColumnFamily cf)
