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)

Reply via email to