This is an automated email from the ASF dual-hosted git repository. huweihua pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push: new 32652e1ea10 [FLINK-33160][network] Log the remote address when an exception occurs in the PartitionRequestQueue 32652e1ea10 is described below commit 32652e1ea10d2578f583f37aeb329e34ad0464c7 Author: caodizhou <caodizho...@bytedance.com> AuthorDate: Tue Oct 24 20:59:13 2023 +0800 [FLINK-33160][network] Log the remote address when an exception occurs in the PartitionRequestQueue --- .../apache/flink/runtime/io/network/netty/PartitionRequestQueue.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java index 31042cfac3a..933e122899a 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/PartitionRequestQueue.java @@ -381,7 +381,10 @@ class PartitionRequestQueue extends ChannelInboundHandlerAdapter { } private void handleException(Channel channel, Throwable cause) throws IOException { - LOG.error("Encountered error while consuming partitions", cause); + LOG.error( + "Encountered error while consuming partitions (connection to {})", + channel.remoteAddress(), + cause); fatalError = true; releaseAllResources();