You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by iw...@apache.org on 2020/01/21 09:31:46 UTC
[hadoop] branch branch-3.2 updated: Remove WARN log when ipc
connection interrupted in Client#handleSaslConnectionFailure()
This is an automated email from the ASF dual-hosted git repository.
iwasakims pushed a commit to branch branch-3.2
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/branch-3.2 by this push:
new c36fbcb Remove WARN log when ipc connection interrupted in Client#handleSaslConnectionFailure()
c36fbcb is described below
commit c36fbcbf1711d01f2b586795b52b47b112c51612
Author: sunlisheng <su...@xiaomi.com>
AuthorDate: Wed Jan 8 10:20:36 2020 +0800
Remove WARN log when ipc connection interrupted in Client#handleSaslConnectionFailure()
Signed-off-by: sunlisheng <su...@xiaomi.com>
(cherry picked from commit d887e49dd4ed2b94bbb53b7608586f5da6cee037)
---
.../src/main/java/org/apache/hadoop/ipc/Client.java | 13 +++++++++++--
1 file changed, 11 insertions(+), 2 deletions(-)
diff --git a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/Client.java b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/Client.java
index 32e71a0..3be5707 100644
--- a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/Client.java
+++ b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/Client.java
@@ -761,8 +761,17 @@ public class Client implements AutoCloseable {
throw (IOException) new IOException(msg).initCause(ex);
}
} else {
- LOG.warn("Exception encountered while connecting to "
- + "the server : " + ex);
+ // With RequestHedgingProxyProvider, one rpc call will send multiple
+ // requests to all namenodes. After one request return successfully,
+ // all other requests will be interrupted. It's not a big problem,
+ // and should not print a warning log.
+ if (ex instanceof InterruptedIOException) {
+ LOG.debug("Exception encountered while connecting to the server",
+ ex);
+ } else {
+ LOG.warn("Exception encountered while connecting to the server ",
+ ex);
+ }
}
if (ex instanceof RemoteException)
throw (RemoteException) ex;
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org