You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Weijie Guo (Jira)" <ji...@apache.org> on 2022/08/03 08:54:00 UTC

[jira] [Reopened] (FLINK-27908) Introduce HsResultPartition and HsSubpartitionView

     [ https://issues.apache.org/jira/browse/FLINK-27908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Weijie Guo reopened FLINK-27908:
--------------------------------

 I accidentally lost several changes when rebase the code. Reopen this ticket to fix this.

> Introduce HsResultPartition and HsSubpartitionView
> --------------------------------------------------
>
>                 Key: FLINK-27908
>                 URL: https://issues.apache.org/jira/browse/FLINK-27908
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Runtime / Network
>            Reporter: Weijie Guo
>            Assignee: Weijie Guo
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.16.0
>
>
> Introduce HsResultPartition and HsSubpartitionView to supports record write and read. The HsResultPartition will append data to HsMemoryDataManager and spill data to disk according to HsSpillingStrategy. Consumer task will register HsSubpartitionView to upstream, poll data from memory or disk.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)