You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by vj...@apache.org on 2020/06/05 15:07:15 UTC
[hbase] branch branch-2.1 updated: HBASE-24499 Use a client
property for SaslConnection MAX_ATTEMPTS (#1857)
This is an automated email from the ASF dual-hosted git repository.
vjasani pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 34884e0 HBASE-24499 Use a client property for SaslConnection MAX_ATTEMPTS (#1857)
34884e0 is described below
commit 34884e09bed0bc2b1bce3954dbe921fbacff7fc5
Author: Ravi Kishore Valeti <v....@gmail.com>
AuthorDate: Fri Jun 5 20:13:08 2020 +0530
HBASE-24499 Use a client property for SaslConnection MAX_ATTEMPTS (#1857)
Signed-off-by: Duo Zhang <zh...@apache.org>
Signed-off-by: Jan Hentschel <ja...@ultratendency.com>
Signed-off-by: Viraj Jasani <vj...@apache.org>
---
.../main/java/org/apache/hadoop/hbase/ipc/BlockingRpcConnection.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/BlockingRpcConnection.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/BlockingRpcConnection.java
index d676d1e..be37553 100644
--- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/BlockingRpcConnection.java
+++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/BlockingRpcConnection.java
@@ -448,7 +448,7 @@ class BlockingRpcConnection extends RpcConnection implements Runnable {
}
short numRetries = 0;
- final short MAX_RETRIES = 5;
+ int reloginMaxRetries = this.rpcClient.conf.getInt("hbase.security.relogin.maxretries", 5);
while (true) {
setupConnection();
InputStream inStream = NetUtils.getInputStream(socket);
@@ -473,7 +473,7 @@ class BlockingRpcConnection extends RpcConnection implements Runnable {
});
} catch (Exception ex) {
ExceptionUtil.rethrowIfInterrupt(ex);
- handleSaslConnectionFailure(numRetries++, MAX_RETRIES, ex, ticket);
+ handleSaslConnectionFailure(numRetries++, reloginMaxRetries, ex, ticket);
continue;
}
if (continueSasl) {