You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2017/05/12 00:23:52 UTC

hbase git commit: HBASE-18021 Add more info in timed out RetriesExhaustedException for read replica client get processing (Huaxiang Sun)

Repository: hbase
Updated Branches:
  refs/heads/master c83347361 -> d64acfd30


HBASE-18021 Add more info in timed out RetriesExhaustedException for read replica client get processing (Huaxiang Sun)


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

Branch: refs/heads/master
Commit: d64acfd3045027e219438ff6c45fd72f0ea5140f
Parents: c833473
Author: Michael Stack <st...@apache.org>
Authored: Thu May 11 17:23:43 2017 -0700
Committer: Michael Stack <st...@apache.org>
Committed: Thu May 11 17:23:43 2017 -0700

----------------------------------------------------------------------
 .../hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hbase/blob/d64acfd3/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java
----------------------------------------------------------------------
diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java
index 0050269..91c6344 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/client/RpcRetryingCallerWithReadReplicas.java
@@ -209,7 +209,9 @@ public class RpcRetryingCallerWithReadReplicas {
       Future<Result> f = cs.pollForFirstSuccessfullyCompletedTask(operationTimeout,
           TimeUnit.MILLISECONDS, startIndex, endIndex);
       if (f == null) {
-        throw new RetriesExhaustedException("timed out after " + operationTimeout + " ms");
+        throw new RetriesExhaustedException("Timed out after " + operationTimeout +
+            "ms. Get is sent to replicas with startIndex: " + startIndex +
+            ", endIndex: " + endIndex + ", Locations: " + rl);
       }
       return f.get();
     } catch (ExecutionException e) {