Nico Kruber created FLINK-9253:
----------------------------------

             Summary: Make buffer count per InputGate always 
#channels*buffersPerChannel + ExclusiveBuffers
                 Key: FLINK-9253
                 URL: https://issues.apache.org/jira/browse/FLINK-9253
             Project: Flink
          Issue Type: Sub-task
          Components: Network
    Affects Versions: 1.5.0, 1.6.0
            Reporter: Nico Kruber
            Assignee: Nico Kruber
             Fix For: 1.5.0


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.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to