Zhilong Hong created FLINK-22284:
------------------------------------
Summary: Null address will be logged when channel is closed in
NettyPartitionRequestClient
Key: FLINK-22284
URL: https://issues.apache.org/jira/browse/FLINK-22284
Project: Flink
Issue Type: Improvement
Components: Runtime / Network
Affects Versions: 1.13.0
Reporter: Zhilong Hong
Fix For: 1.13.0
In NettyPartitionRequestClient#requestSubpartition, when channel is closed, the
channel will throw a LocalTransportException with the error message "Sending
the partition request to 'null' failed.". The message is confusing since we
wouldn't know where the remote client connected to this channel locates, and we
couldn't track down to that TaskExecutor and find out what happened.
Also I'm wondering that should we use TransportException instead of
LocalTransportException here, because it's a little confusing to see a
LocalTransportException is thrown out when a remote channel is closed.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
