Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6291#discussion_r201304267
--- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestClientHandler.java
---
@@ -164,7 +164,9 @@ public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause)
throws E
+ "that the remote task manager was lost.", remoteAddr, cause);
}
else {
- tex = new LocalTransportException(cause.getMessage(), ctx.channel().localAddress(),
cause);
+ SocketAddress localAddr = ctx.channel().localAddress();
+ tex = new LocalTransportException(cause.getMessage() + " (connection to '" + remoteAddr
+ "')",
--- End diff --
the same
---
|