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

[hu...@apache.org]

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 <ca...@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();