(flink) branch master updated: [FLINK-33160][network] Log the remote address when an exception occurs in the PartitionRequestQueue

[huweihua]

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();