Index: src/java/org/apache/hadoop/hbase/regionserver/HStoreScanner.java =================================================================== --- src/java/org/apache/hadoop/hbase/regionserver/HStoreScanner.java (revision 649252) +++ src/java/org/apache/hadoop/hbase/regionserver/HStoreScanner.java (working copy) @@ -219,9 +219,6 @@ moreToFollow = chosenTimestamp >= 0; if (dataFilter != null) { - if (moreToFollow) { - dataFilter.rowProcessed(filtered, chosenRow); - } if (dataFilter.filterAllRemaining()) { moreToFollow = false; } Index: src/java/org/apache/hadoop/hbase/regionserver/HRegion.java =================================================================== --- src/java/org/apache/hadoop/hbase/regionserver/HRegion.java (revision 649252) +++ src/java/org/apache/hadoop/hbase/regionserver/HRegion.java (working copy) @@ -1804,8 +1804,13 @@ } filtered = filter == null ? false : filter.filterNotNull(results); - - if (filtered && moreToFollow) { - results.clear(); + + if (moreToFollow) { + if (filter != null) { + filter.rowProcessed(filtered, key.getRow()); + } + if (filtered) { + results.clear(); + } } } while(filtered && moreToFollow);