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
---
