HBASE-8942 DFS errors during a read operation (get/scan), may cause write outliers
git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1538317 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
679495a01c
commit
b0c406da07
|
@ -1678,21 +1678,16 @@ public class HStore implements Store {
|
|||
//////////////////////////////////////////////////////////////////////////////
|
||||
|
||||
@Override
|
||||
public KeyValueScanner getScanner(Scan scan,
|
||||
final NavigableSet<byte []> targetCols, long readPt) throws IOException {
|
||||
lock.readLock().lock();
|
||||
try {
|
||||
KeyValueScanner scanner = null;
|
||||
if (this.getCoprocessorHost() != null) {
|
||||
scanner = this.getCoprocessorHost().preStoreScannerOpen(this, scan, targetCols);
|
||||
}
|
||||
if (scanner == null) {
|
||||
scanner = new StoreScanner(this, getScanInfo(), scan, targetCols, readPt);
|
||||
}
|
||||
return scanner;
|
||||
} finally {
|
||||
lock.readLock().unlock();
|
||||
public KeyValueScanner getScanner(Scan scan, final NavigableSet<byte[]> targetCols, long readPt)
|
||||
throws IOException {
|
||||
KeyValueScanner scanner = null;
|
||||
if (this.getCoprocessorHost() != null) {
|
||||
scanner = this.getCoprocessorHost().preStoreScannerOpen(this, scan, targetCols);
|
||||
}
|
||||
if (scanner == null) {
|
||||
scanner = new StoreScanner(this, getScanInfo(), scan, targetCols, readPt);
|
||||
}
|
||||
return scanner;
|
||||
}
|
||||
|
||||
@Override
|
||||
|
|
Loading…
Reference in New Issue