STORM-3374 remove unnecessary stacktrace from log

jyh2015 · Apr 15, 2019 · 0dafa83 · 0dafa83
1 parent 1976cb3
commit 0dafa83
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/storm-client/src/jvm/org/apache/storm/messaging/netty/StormClientHandler.java b/storm-client/src/jvm/org/apache/storm/messaging/netty/StormClientHandler.java
@@ -12,6 +12,7 @@
 
 package org.apache.storm.messaging.netty;
 
+import java.io.IOException;
 import java.net.ConnectException;
 import java.util.List;
 import java.util.Map;
@@ -96,7 +97,11 @@ public void channelRead(ChannelHandlerContext ctx, Object message) throws Except
     @Override
     public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
         if (!(cause instanceof ConnectException)) {
-            LOG.info("Connection to " + client.getDstAddress() + " failed:", cause);
+            if (cause instanceof IOException) {
+                LOG.info("Connection to {} failed: {}", client.getDstAddress(), cause.getMessage());
+            } else {
+                LOG.error("Connection to {} failed: {}", client.getDstAddress(), cause);
+            }
         }
     }
 }