You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/09/20 10:59:00 UTC

[jira] [Created] (FLINK-29351) Enable input buffer floating for blocking shuffle

Yingjie Cao created FLINK-29351:
-----------------------------------

             Summary: Enable input buffer floating for blocking shuffle
                 Key: FLINK-29351
                 URL: https://issues.apache.org/jira/browse/FLINK-29351
             Project: Flink
          Issue Type: Improvement
          Components: Runtime / Network
            Reporter: Yingjie Cao
             Fix For: 1.17.0


At input gate, Flink needs exclusive buffers for each input channel. For large parallelism jobs, it is easy to cause "Insufficient number of network buffers" error. This ticket aims to make all input network buffers floating for blocking shuffle to reduce the possibility of "Insufficient number of network buffers" error. This change can also improve the default blocking shuffle performance because buffer floating can increase the buffer utilization.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)