[ https://issues.apache.org/jira/browse/FLINK-28823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Yingjie Cao reassigned FLINK-28823: ----------------------------------- Assignee: Yuxin Tan > Enlarge the max requested buffers for SortMergeResultPartitionReadScheduler > --------------------------------------------------------------------------- > > Key: FLINK-28823 > URL: https://issues.apache.org/jira/browse/FLINK-28823 > Project: Flink > Issue Type: Sub-task > Components: Runtime / Network > Affects Versions: 1.16.0 > Reporter: Yuxin Tan > Assignee: Yuxin Tan > Priority: Major > Labels: pull-request-available > > The num of the max requested buffers in SortMergeResultPartitionReadScheduler > is determined by the num of subpartitions, which may be insufficient in some > scenarios, such as speculative execution and partition reuse. > Therefore, we should increase the max requested buffers to make full use of > available memory when TM memory is sufficient. > -- This message was sent by Atlassian Jira (v8.20.10#820010)