azagrebin commented on issue #8463: [FLINK-12530][network] Move
Task.inputGatesById to NetworkEnvironment
URL: https://github.com/apache/flink/pull/8463#issuecomment-497091861
Thanks for the reviews @tillrohrmann @zhijiangW !
I squashed the commits and adjusted the comments.
--
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
p
azagrebin commented on issue #8463: [FLINK-12530][network] Move
Task.inputGatesById to NetworkEnvironment
URL: https://github.com/apache/flink/pull/8463#issuecomment-495525981
Thanks for the review @zhijiangW, I've addressed comments.
I think `PartitionProducerStateChecker` and `Partitio
azagrebin commented on issue #8463: [FLINK-12530][network] Move
Task.inputGatesById to NetworkEnvironment
URL: https://github.com/apache/flink/pull/8463#issuecomment-495522841
Thanks for the further review @tillrohrmann. I have addressed comments.
--
azagrebin commented on issue #8463: [FLINK-12530][network] Move
Task.inputGatesById to NetworkEnvironment
URL: https://github.com/apache/flink/pull/8463#issuecomment-494427067
I have also pushed one more hotfix to separate `PartitionProducerChecker`
interface from `TaskActions` because it
azagrebin commented on issue #8463: [FLINK-12530][network] Move
Task.inputGatesById to NetworkEnvironment
URL: https://github.com/apache/flink/pull/8463#issuecomment-494409523
Thanks for the review @tillrohrmann @zhijiangW !
I have addressed the comments
azagrebin commented on issue #8463: [FLINK-12530][network] Move
Task.inputGatesById to NetworkEnvironment
URL: https://github.com/apache/flink/pull/8463#issuecomment-492992119
@flinkbot attention @zhijiangW
This is an automa
