[ https://issues.apache.org/jira/browse/FLINK-9755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16549711#comment-16549711 ]
ASF GitHub Bot commented on FLINK-9755: --------------------------------------- Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6272 > Exceptions in RemoteInputChannel#notifyBufferAvailable() are not propagated > to the responsible thread > ----------------------------------------------------------------------------------------------------- > > Key: FLINK-9755 > URL: https://issues.apache.org/jira/browse/FLINK-9755 > Project: Flink > Issue Type: Bug > Components: Network > Affects Versions: 1.5.0 > Reporter: Nico Kruber > Assignee: Nico Kruber > Priority: Critical > Labels: pull-request-available > Fix For: 1.5.2, 1.6.0 > > > The credit-based flow control implementation of > RemoteInputChannel#notifyBufferAvailable() does not forward errors (like the > {{IllegalStateException}}) to the thread that is being notified. The calling > code at {{LocalBufferPool#recycle}}, however, relies on the callback > forwarding errors and completely ignores any failures. > Therefore, we could end up with a program waiting forever for the callback > and not even a failure message in the logs. -- This message was sent by Atlassian JIRA (v7.6.3#76005)