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 2020/10/13 05:59:00 UTC

[jira] [Created] (FLINK-19597) Introduce SortBuffer and its implementation PartitionSortedBuffer for sort-merge based blocking shuffle

Yingjie Cao created FLINK-19597:
-----------------------------------

             Summary: Introduce SortBuffer and its implementation PartitionSortedBuffer for sort-merge based blocking shuffle
                 Key: FLINK-19597
                 URL: https://issues.apache.org/jira/browse/FLINK-19597
             Project: Flink
          Issue Type: Sub-task
          Components: Runtime / Network
    Affects Versions: 1.12.0
            Reporter: Yingjie Cao
             Fix For: 1.12.0


Data of different channels can be appended to a SortBuffer and after the SortBuffer is finished, the appended data can be copied from it in channel index order. PartitionSortedBuffer is an implementation of SortBuffer and it sorts all appended records only by subpartition index. Records of the same subpartition keep the appended order.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)