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/10/26 11:56:00 UTC

[jira] [Updated] (FLINK-29768) Hybrid shuffle supports the update of ResultPartition information

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

Weijie Guo updated FLINK-29768:
-------------------------------
    Affects Version/s: 1.17.0

> Hybrid shuffle supports the update of ResultPartition information
> -----------------------------------------------------------------
>
>                 Key: FLINK-29768
>                 URL: https://issues.apache.org/jira/browse/FLINK-29768
>             Project: Flink
>          Issue Type: Sub-task
>    Affects Versions: 1.17.0
>            Reporter: Weijie Guo
>            Priority: Major
>
> At present, only the blocking edge in the pipelinedRegion can send the RPC of `updatePartitionInfo`. However, through the enhancement of the `AdaptiveBatchScheduler`, we can now schedule downstream tasks when the upstream's some subtask is not completely finished. After the upstream task's data is totally produced, we need to update the result partition's information of this subtask to trigger downstream task's consumption.



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