flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yanghua <...@git.apache.org>
Subject [GitHub] flink pull request #6291: [FLINK-9785][network] add remote address informati...
Date Tue, 10 Jul 2018 11:16:07 GMT
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


---

Mime
View raw message