Yingjie Cao created FLINK-28519:
-----------------------------------
Summary: Fix the bug that SortMergeResultPartitionReadScheduler
may not read data sequentially
Key: FLINK-28519
URL: https://issues.apache.org/jira/browse/FLINK-28519
Project: Flink
Issue Type: Sub-task
Components: Runtime / Network
Reporter: Yingjie Cao
Fix For: 1.16.0
Currently, the SortMergeResultPartitionReadScheduler always gets all active
subpartition readers and read at most one data region for them. It is common
that some subpartitions are requested before others and their region indexes
are ahead of others. If all region data of a subpartition can be read in one
round, some subpartition readers will always ahead of others which will cause
random IO. This patch fixes this case by polling one subpartition reader at a
time.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
