[FLINK-9253] Make buffer count per InputGate always #channels*buffersPerChannel + ExclusiveBuffers

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Won't Fix
• Affects Version/s: 1.5.0, 1.6.0
• Component/s: Runtime / Network
• Labels: pull-request-available
• Assignee: Nico Kruber
• Reporter: Nico Kruber
• Created: 25/Apr/18 13:45
• Updated: 10/Nov/20 15:36
• Resolved: 10/Nov/20 15:36

Description

The credit-based flow control path assigns exclusive buffers only to remote channels (which makes sense since local channels don't use any own buffers). However, this is a bit intransparent with respect to how much data may be in buffers since this depends on the actual schedule of the job and not the job graph.

By adapting the floating buffers to use a maximum of #channels*buffersPerChannel + floatingBuffersPerGate - #exclusiveBuffers, we would be channel-type agnostic and keep the old behaviour.

Issue Links

• links to: GitHub Pull Request #5923
• links to: GitHub Pull Request #5923