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 da032cbeb9d1..d63d14940e78 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 @@ -395,7 +395,8 @@ public Object run() throws IOException, InterruptedException { // A provider which failed authentication, but doesn't have the ability to relogin with // some external system (e.g. username/password, the password either works or it doesn't) if (!provider.canRetry()) { - LOG.warn("Exception encountered while connecting to the server : " + ex); + LOG.warn("Exception encountered while connecting to the server " + remoteId.getAddress(), + ex); if (ex instanceof RemoteException) { throw (RemoteException) ex; } @@ -410,7 +411,8 @@ public Object run() throws IOException, InterruptedException { // Other providers, like kerberos, could request a new ticket from a keytab. Let // them try again. if (currRetries < maxRetries) { - LOG.debug("Exception encountered while connecting to the server", ex); + LOG.debug("Exception encountered while connecting to the server " + remoteId.getAddress(), + ex); // Invoke the provider to perform the relogin provider.relogin(); diff --git a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcConnection.java b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcConnection.java index 3b5b6a5581cd..3ed259f2f286 100644 --- a/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcConnection.java +++ b/hbase-client/src/main/java/org/apache/hadoop/hbase/ipc/NettyRpcConnection.java @@ -314,7 +314,10 @@ private void succeed(Channel ch) throws IOException { } private void fail(Channel ch, Throwable error) { - failInit(ch, toIOE(error)); + IOException ex = toIOE(error); + LOG.warn("Exception encountered while connecting to the server " + remoteId.getAddress(), + ex); + failInit(ch, ex); rpcClient.failedServers.addToFailedServers(remoteId.getAddress(), error); }