[GitHub] [flink] zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface

2020-04-08 Thread GitBox
zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface URL: https://github.com/apache/flink/pull/11647#discussion_r405991335 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/topology/ILogicalPipelinedRe

[GitHub] [flink] zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface

2020-04-08 Thread GitBox
zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface URL: https://github.com/apache/flink/pull/11647#discussion_r405991335 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/topology/ILogicalPipelinedRe

[GitHub] [flink] zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface

2020-04-08 Thread GitBox
zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface URL: https://github.com/apache/flink/pull/11647#discussion_r405987424 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/topology/SimpleTopology.java ###

[GitHub] [flink] zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface

2020-04-08 Thread GitBox
zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface URL: https://github.com/apache/flink/pull/11647#discussion_r405984395 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/topology/Topology.java ## @

[GitHub] [flink] zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface

2020-04-08 Thread GitBox
zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface URL: https://github.com/apache/flink/pull/11647#discussion_r405984395 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/topology/Topology.java ## @

[GitHub] [flink] zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface

2020-04-06 Thread GitBox
zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface URL: https://github.com/apache/flink/pull/11647#discussion_r404524838 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/topology/Topology.java ## @

[GitHub] [flink] zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface

2020-04-06 Thread GitBox
zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface URL: https://github.com/apache/flink/pull/11647#discussion_r404524838 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/topology/Topology.java ## @

[GitHub] [flink] zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface

2020-04-06 Thread GitBox
zhuzhurk commented on a change in pull request #11647: [FLINK-16960][runtime] Add PipelinedRegion interface URL: https://github.com/apache/flink/pull/11647#discussion_r404521204 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/topology/PipelinedRegion.java ##