[ https://issues.apache.org/jira/browse/FLINK-29299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Yingjie Cao resolved FLINK-29299. --------------------------------- Resolution: Fixed Fix via d3513d98953b0922e3dc753ef90806ed4e264926 on master 7367e358ccf34fb1e9ea2cea9d5b1f630b00e10c on 1.16 > Fix the network memory size calculation issue in fine-grained resource mode > --------------------------------------------------------------------------- > > Key: FLINK-29299 > URL: https://issues.apache.org/jira/browse/FLINK-29299 > Project: Flink > Issue Type: Bug > Components: Runtime / Network > Affects Versions: 1.16.0 > Reporter: Yingjie Cao > Assignee: Yingjie Cao > Priority: Critical > Labels: pull-request-available > Fix For: 1.16.0 > > > After FLINK-28663, one intermediate dataset can be consumed by multiple > consumers, there is a case where one vertex can consume one intermediate > dataset multiple times. However, currently in fine-grained resource mode, > when computing the required network buffer size, the intermediate dataset is > used as key to record the size of network buffer per input gate, which means > it may allocate less network buffers than needed if two input gate of the > same vertex consumes the same intermediate dataset. -- This message was sent by Atlassian Jira (v8.20.10#820010)