flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Piotr Nowojski (Jira)" <j...@apache.org>
Subject [jira] [Commented] (FLINK-21952) Make all the "Connection reset by peer" exception wrapped as RemoteTransportException
Date Mon, 03 May 2021 05:09:00 GMT

    [ https://issues.apache.org/jira/browse/FLINK-21952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17338171#comment-17338171
] 

Piotr Nowojski commented on FLINK-21952:
----------------------------------------

How would you propose [~gaoyunhaii] to solve this?

> Make all the "Connection reset by peer" exception wrapped as RemoteTransportException
> -------------------------------------------------------------------------------------
>
>                 Key: FLINK-21952
>                 URL: https://issues.apache.org/jira/browse/FLINK-21952
>             Project: Flink
>          Issue Type: Bug
>          Components: Runtime / Network
>            Reporter: Yun Gao
>            Priority: Major
>              Labels: stale-major
>
> 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 
> {code:java}
> org.apache.flink.shaded.netty4.io.netty.channel.unix.Errors$NativeIoException: readAddress(..)
failed: Connection reset by peer
> {code}
> in some case. It would be also wrapped as LocalTransportException, which might cause
some confusion. 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Mime
View raw message