Repository: hbase Updated Branches: refs/heads/branch-1 ffa3785d0 -> 9bf5bc198 refs/heads/branch-1.3 80d7d1a59 -> 5cbc041b9 refs/heads/master 589563163 -> c83347361
Amend HBASE-18000 Make sure we always return the scanner id with ScanResponse (Karan Mehta and Duo Zhang) Move getRegionScanner() call below builder.setScannerId() to handle a corner case. Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/c8334736 Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/c8334736 Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/c8334736 Branch: refs/heads/master Commit: c833473619d5a2ff9437d62f2ea14ac772288304 Parents: 5895631 Author: Andrew Purtell <apurt...@apache.org> Authored: Thu May 11 14:34:04 2017 -0700 Committer: Andrew Purtell <apurt...@apache.org> Committed: Thu May 11 14:35:23 2017 -0700 ---------------------------------------------------------------------- .../java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/c8334736/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java index 34401f2..95408b7 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/RSRpcServices.java @@ -3058,10 +3058,10 @@ public class RSRpcServices implements HBaseRPCErrorHandler, ScanResponse.Builder builder = ScanResponse.newBuilder(); try { if (request.hasScannerId()) { - rsh = getRegionScanner(request); // The downstream projects such as AsyncHBase in OpenTSDB need this value. See HBASE-18000 // for more details. builder.setScannerId(request.getScannerId()); + rsh = getRegionScanner(request); } else { rsh = newRegionScanner(request, builder); }
