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

HBASE-13071 synchronous scanner -- cache size-in-bytes bug fix 

Signed-off-by: stack <stack@apache.org>
This commit is contained in:
eshcar 2015-05-17 23:01:40 +03:00 committed by stack
parent dc72dad7cd
commit 7f2b33dbbf
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
hbase-client/src/main/java/org/apache/hadoop/hbase/client/ClientAsyncPrefetchScanner.java
View File

@ -104,10 +104,7 @@ public class ClientAsyncPrefetchScanner extends ClientScanner {
while (isPrefetchRunning()) {
// prefetch running or still pending
if (getCacheCount() > 0) {
Result res = cache.poll();
long estimatedSize = calcEstimatedSize(res);
addEstimatedSize(-estimatedSize);
return res;
return pollCache();
} else {
// (busy) wait for a record - sleep
Threads.sleep(1);
@ -115,7 +112,7 @@ public class ClientAsyncPrefetchScanner extends ClientScanner {
}
if (getCacheCount() > 0) {
return cache.poll();
return pollCache();
}
// if we exhausted this scanner before calling close, write out the scan metrics
@ -209,6 +206,12 @@ public class ClientAsyncPrefetchScanner extends ClientScanner {
return cacheSizeInBytes.get();
}
private Result pollCache() {
Result res = cache.poll();
long estimatedSize = calcEstimatedSize(res);
addEstimatedSize(-estimatedSize);
return res;
}
private class PrefetchRunnable implements Runnable {