Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-14895 Seek only to the newly flushed file on scanner reset on flush 

- Addendum (Ram)
This commit is contained in:
ramkrishna 2015-12-15 10:34:25 +05:30
parent 10d86c7dae
commit 1822bb5d95
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java
View File

@ -414,7 +414,6 @@ public class StoreScanner extends NonReversedNonLazyKeyValueScanner
@Override @Override
public Cell peek() { public Cell peek() {
checkFlushed();
if (this.heap == null) { if (this.heap == null) {
return this.lastTop; return this.lastTop;
} }
@ -810,7 +809,7 @@ public class StoreScanner extends NonReversedNonLazyKeyValueScanner
// If there is a flush and the current scan is notified on the flush ensure that the // If there is a flush and the current scan is notified on the flush ensure that the
// scan's heap gets reset and we do a seek on the newly flushed file. // scan's heap gets reset and we do a seek on the newly flushed file.
if(!this.closing) { if(!this.closing) {
this.lastTop = this.heap.peek(); this.lastTop = this.peek();
} else { } else {
return false; return false;
} }