[FLINK-10332] Move data available notification in PipelinedSubpartition out of the synchronized block

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.5.0, 1.5.1, 1.5.2, 1.5.3, 1.6.0, 1.7.0
• Fix Version/s: 1.5.5, 1.6.2, 1.7.0
• Component/s: Runtime / Network
• Labels: pull-request-available
• Assignee: Nico Kruber
• Reporter: Nico Kruber
• Created: 13/Sep/18 08:42
• Updated: 17/Oct/18 08:44
• Resolved: 19/Sep/18 19:37

Description

Currently, calls to PipelinedSubpartition#notifyDataAvailable(); are unnecessarily executed inside a synchronized (buffers) block which may lead to lock contention.

Issue Links

• links to: GitHub Pull Request #6693