[GitHub] [flink] zhuzhurk commented on pull request #14463: [FLINK-20721][runtime] Remove unknown input channel and the process which updates it

[GitBox <gi...@apache.org>]

zhuzhurk commented on pull request #14463:
URL: https://github.com/apache/flink/pull/14463#issuecomment-750139675


   Closing this ticket because UnknownInputChannel are still needed at the moment if BLOCKING edges exist in a pipelined region.
   
   e.g.
   A – pipelined --> B, A – pipelined --> C, B – pipelined --> D, C – blocking --> D.
   
   In this case, even though D knows the location of C when deployed, the corresponding input channel will be unknown because C has not finished producing the BLOCKING result partition. This is needed because reading from an uncompleted BLOCKING result partition is not supported yet.
   
   Besides that, UnknownInputChannel is possibly needed for future individual failover.


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org