You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Nico Kruber (JIRA)" <ji...@apache.org> on 2018/07/04 22:43:00 UTC
[jira] [Created] (FLINK-9756) Exceptions in
BufferListener#notifyBufferAvailable do not trigger further listeners in
LocalBufferPool#recycle()
Nico Kruber created FLINK-9756:
----------------------------------
Summary: Exceptions in BufferListener#notifyBufferAvailable do not trigger further listeners in LocalBufferPool#recycle()
Key: FLINK-9756
URL: https://issues.apache.org/jira/browse/FLINK-9756
Project: Flink
Issue Type: Bug
Components: Network
Affects Versions: 1.5.0
Reporter: Nico Kruber
Assignee: Nico Kruber
Fix For: 1.6.0, 1.5.2
Any {{Exception}} thrown in {{BufferListener#notifyBufferAvailable}} will currently not trigger calling further listeners in {{LocalBufferPool#recycle()}} and only add the given memory segment to the queue of available ones.
Usually this will not be the last call to {{recycle()}} and future calls may call the listeners but this also introduces further delay in configurations with tight numbers of buffers in the local pool and listeners waiting on them when one task's listener was failing.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)