Index: hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java =================================================================== --- hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java (revision 1372673) +++ hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/HRegion.java (working copy) @@ -3616,16 +3616,15 @@ } } - private boolean filterRow() { - return filter != null - && filter.filterRow(); - } private boolean filterRowKey(byte[] row) { return filter != null && filter.filterRowKey(row, 0, row.length); } protected void nextRow(byte [] currentRow) throws IOException { + KeyValue kv = KeyValue.createLastOnRow(currentRow); + this.storeHeap.requestSeek(kv, true, true); + while (Bytes.equals(currentRow, peekRow())) { this.storeHeap.next(MOCKED_LIST); }