azagrebin commented on issue #8463: [FLINK-12530][network] Move Task.inputGatesById to NetworkEnvironment URL: https://github.com/apache/flink/pull/8463#issuecomment-496123283 Thanks for the thoughts @zhijiangW ! True, this state might be not final. Further steps in this topic are probably more related to the partition lifecycle management and out of scope of this PR. The main motivation of introducing the `PartitionProducerChecker` now was to separate it from `TaskActions`. `TaskActions` is very broad interface used in other components for unrelated purposes. Shuffle API does not need it in the scope of the first refactoring. Introducing `PartitionProducerChecker` improves Shuffle API decoupling because it reflects only what is needed at the moment. I can move this hotfix into another PR if it feels like this but it is small and has been already reviewed. Also the related code is touched anyway in this PR.
---------------------------------------------------------------- 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: [email protected] With regards, Apache Git Services
