From 0e64f91e37a1187ca22ca8d90fab3b382305d63d Mon Sep 17 00:00:00 2001 From: Zhihong Yu Date: Mon, 21 Oct 2013 03:18:25 +0000 Subject: [PATCH] HBASE-9754 Addendum passes readpoint to StoreScanner ctor git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1534019 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/hadoop/hbase/regionserver/StoreScanner.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) 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 4a4d6017e5f..54e8926d7c8 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 @@ -34,6 +34,7 @@ import org.apache.hadoop.hbase.DoNotRetryIOException; import org.apache.hadoop.hbase.HConstants; import org.apache.hadoop.hbase.KeyValue; import org.apache.hadoop.hbase.KeyValueUtil; +import org.apache.hadoop.hbase.client.IsolationLevel; import org.apache.hadoop.hbase.client.Scan; import org.apache.hadoop.hbase.executor.ExecutorService; import org.apache.hadoop.hbase.filter.Filter; @@ -223,8 +224,8 @@ public class StoreScanner extends NonLazyKeyValueScanner private StoreScanner(Store store, ScanInfo scanInfo, Scan scan, List scanners, ScanType scanType, long smallestReadPoint, long earliestPutTs, byte[] dropDeletesFromRow, byte[] dropDeletesToRow) throws IOException { - this(store, false, scan, null, scanInfo.getTtl(), - scanInfo.getMinVersions(), smallestReadPoint); + this(store, false, scan, null, scanInfo.getTtl(), scanInfo.getMinVersions(), + ((HStore)store).getHRegion().getReadpoint(IsolationLevel.READ_COMMITTED)); if (dropDeletesFromRow == null) { matcher = new ScanQueryMatcher(scan, scanInfo, null, scanType, smallestReadPoint, earliestPutTs, oldestUnexpiredTS);