[FLINK-9756] Exceptions in BufferListener#notifyBufferAvailable do not trigger further listeners in LocalBufferPool#recycle()

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Invalid
• Affects Version/s: 1.5.0
• Component/s: Runtime / Network
• Assignee: Nico Kruber
• Reporter: Nico Kruber
• Created: 04/Jul/18 22:42
• Updated: 05/Jul/18 21:30
• Resolved: 05/Jul/18 21:30

Description

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.

Issue Links

• is related to: FLINK-9755 Exceptions in RemoteInputChannel#notifyBufferAvailable() are not propagated to the responsible thread