You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Yingjie Cao (Jira)" <ji...@apache.org> on 2022/07/12 12:16:00 UTC
[jira] [Created] (FLINK-28519) Fix the bug that SortMergeResultPartitionReadScheduler may not read data sequentially
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)