hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From st...@apache.org
Subject [02/30] hbase git commit: HBASE-18122 addendum for fixing async client scanner
Date Wed, 31 May 2017 16:31:31 GMT
HBASE-18122 addendum for fixing async client scanner


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

Branch: refs/heads/HBASE-14614
Commit: c945d2b2d9dc2b9223819842239997efa10f4c0b
Parents: 9cf1a08
Author: Phil Yang <yangzhe1991@apache.org>
Authored: Wed May 31 15:30:24 2017 +0800
Committer: Phil Yang <yangzhe1991@apache.org>
Committed: Wed May 31 15:30:24 2017 +0800

----------------------------------------------------------------------
 .../hadoop/hbase/client/AsyncRpcRetryingCallerFactory.java       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/c945d2b2/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRpcRetryingCallerFactory.java
----------------------------------------------------------------------
diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRpcRetryingCallerFactory.java
b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRpcRetryingCallerFactory.java
index d71b428..270f265 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRpcRetryingCallerFactory.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/AsyncRpcRetryingCallerFactory.java
@@ -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"),


Mime
View raw message