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)