Weijie Guo created FLINK-29768: ---------------------------------- Summary: 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 Reporter: Weijie Guo
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)