.../org/apache/hadoop/hbase/regionserver/ReversedStoreScanner.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/ReversedStoreScanner.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/ReversedStoreScanner.java index 0e1d90f..2806fe5 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/ReversedStoreScanner.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/ReversedStoreScanner.java @@ -123,12 +123,14 @@ class ReversedStoreScanner extends StoreScanner implements KeyValueScanner { @Override public boolean seekToPreviousRow(Cell key) throws IOException { + checkResetHeap(); checkReseek(); return this.heap.seekToPreviousRow(key); } - + @Override public boolean backwardSeek(Cell key) throws IOException { + checkResetHeap(); checkReseek(); return this.heap.backwardSeek(key); }