[jira] [Created] (FLINK-24469) Incorrect calcualtion of the buffer size in case of channel data skew

["Anton Kalashnikov (Jira)" <ji...@apache.org>]

Anton Kalashnikov created FLINK-24469:
-----------------------------------------

             Summary: Incorrect calcualtion of the buffer size in case of channel data skew
                 Key: FLINK-24469
                 URL: https://issues.apache.org/jira/browse/FLINK-24469
             Project: Flink
          Issue Type: Bug
            Reporter: Anton Kalashnikov
            Assignee: Anton Kalashnikov


If only a couple out of 100 input channels are active then there is a huge throughput drop is observed. I suppose it happens because of the line inside of SingleInputGate#getBuffersInUseCount:

{noformat}

Math.max(1, channel.getBuffersInUseCount());

{noformat}

Right now, I don't think that it makes sense to have min value as 1, perhaps zero buffer in use is also ok.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)