Yuxin Tan created FLINK-28828: --------------------------------- Summary: Sorting all unfinished readers in batches at one time in SortMergeResultPartitionReadScheduler Key: FLINK-28828 URL: https://issues.apache.org/jira/browse/FLINK-28828 Project: Flink Issue Type: Sub-task Components: Runtime / Network Affects Versions: 1.16.0 Reporter: Yuxin Tan
Currently, when reading data in SortMergeResultPartitionReadScheduler, the reader is added to the priority queue immediately. However, the data read from this reader may not have been consumed, which will cause this reader to be ranked later in the queue, which is unfavorable to sequential reading. To solve the issue, After reading the data, we should sort all unfinished readers in batches at one time, that is, add all unfinished readers to the priority queue, which is more conducive to sequential reading. -- This message was sent by Atlassian Jira (v8.20.10#820010)