[FLINK-21952] Make all the "Connection reset by peer" exception wrapped as RemoteTransportException

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.14.0, 1.13.1, 1.12.4
• Fix Version/s: 1.14.0, 1.12.5, 1.13.2
• Component/s: Runtime / Network
• Labels: pull-request-available
• Assignee: Yun Gao
• Reporter: Yun Gao
• Created: 24/Mar/21 12:41
• Updated: 23/Sep/21 17:26
• Resolved: 21/Jun/21 07:36

Description

In CreditBasedPartitionRequestClientHandler#exceptionCaught, the IOException or the exception with exact message "Connection reset by peer" are marked as RemoteTransportException. 

However, with the current Netty implementation, sometimes it might throw 

org.apache.flink.shaded.netty4.io.netty.channel.unix.Errors$NativeIoException: readAddress(..) failed: Connection reset by peer

in some case. It would be also wrapped as LocalTransportException, which might cause some confusion. 

Issue Links

• links to: GitHub Pull Request #16194
• links to: Pull Request 16194