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

HBASE-18122 addendum for fixing async client scanner

This commit is contained in:
Phil Yang 2017-05-31 15:30:24 +08:00
parent 9cf1a08c53
commit c945d2b2d9
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRpcRetryingCallerFactory.java
View File

@ -144,7 +144,7 @@ class AsyncRpcRetryingCallerFactory {
public class ScanSingleRegionCallerBuilder extends BuilderBase {
private long scannerId = -1L;
private Long scannerId = null;
private Scan scan;
@ -238,7 +238,7 @@ class AsyncRpcRetryingCallerFactory {
}
public AsyncScanSingleRegionRpcRetryingCaller build() {
checkArgument(scannerId >= 0, "invalid scannerId %d", scannerId);
checkArgument(scannerId != null, "invalid scannerId %d", scannerId);
return new AsyncScanSingleRegionRpcRetryingCaller(retryTimer, conn,
checkNotNull(scan, "scan is null"), scanMetrics, scannerId,
checkNotNull(resultCache, "resultCache is null"),