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)

Reply via email to