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) {
