From 0dafa836071578c9c0db125066f151665cc474ad Mon Sep 17 00:00:00 2001 From: Aaron Gresch Date: Thu, 4 Apr 2019 15:22:53 -0500 Subject: [PATCH] STORM-3374 remove unnecessary stacktrace from log --- .../apache/storm/messaging/netty/StormClientHandler.java | 7 ++++++- 1 file changed, 6 insertions(+), 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 index 1661fc346a..90d03d6b3e 100644 --- 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); + } } } }