hadoop-common-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From iwasak...@apache.org
Subject [hadoop] branch branch-3.1 updated: Remove WARN log when ipc connection interrupted in Client#handleSaslConnectionFailure()
Date Tue, 21 Jan 2020 09:39:27 GMT
This is an automated email from the ASF dual-hosted git repository.

iwasakims pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/hadoop.git


The following commit(s) were added to refs/heads/branch-3.1 by this push:
     new 96c653d  Remove WARN log when ipc connection interrupted in Client#handleSaslConnectionFailure()
96c653d is described below

commit 96c653d0d5d287627ca20136f6b951427d4bd631
Author: sunlisheng <sunlisheng@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 <sunlisheng@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


Mime
View raw message