HBASE-16362 Mob compaction does not set cacheBlocks to false when creating 
StoreScanner


Project: http://git-wip-us.apache.org/repos/asf/hbase/repo
Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/977858c9
Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/977858c9
Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/977858c9

Branch: refs/heads/hbase-12439
Commit: 977858c9cbdcc7fbdc284e21483ba61a744d6c02
Parents: 938ee73
Author: zhangduo <zhang...@apache.org>
Authored: Fri Aug 5 13:58:02 2016 +0800
Committer: zhangduo <zhang...@apache.org>
Committed: Sat Aug 6 22:38:26 2016 +0800

----------------------------------------------------------------------
 .../java/org/apache/hadoop/hbase/regionserver/StoreScanner.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/977858c9/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java
----------------------------------------------------------------------
diff --git 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java
 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java
index 91a77ea..e008a40 100644
--- 
a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java
+++ 
b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/StoreScanner.java
@@ -319,7 +319,8 @@ public class StoreScanner extends 
NonReversedNonLazyKeyValueScanner
   public StoreScanner(final Scan scan, ScanInfo scanInfo, ScanType scanType,
       final NavigableSet<byte[]> columns, final List<KeyValueScanner> 
scanners, long earliestPutTs,
       long readPt) throws IOException {
-    this(null, scan, scanInfo, columns, readPt, scan.getCacheBlocks());
+    this(null, scan, scanInfo, columns, readPt,
+        scanType == ScanType.USER_SCAN ? scan.getCacheBlocks() : false);
     if (scanType == ScanType.USER_SCAN) {
       this.matcher = UserScanQueryMatcher.create(scan, scanInfo, columns, 
oldestUnexpiredTS, now,
         null);

Reply via email to