[GitHub] [flink] azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods

2019-05-29 Thread GitBox
azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods URL: https://github.com/apache/flink/pull/8529#discussion_r288489819 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanag

[GitHub] [flink] azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods

2019-05-28 Thread GitBox
azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods URL: https://github.com/apache/flink/pull/8529#discussion_r288210117 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/

[GitHub] [flink] azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods

2019-05-28 Thread GitBox
azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods URL: https://github.com/apache/flink/pull/8529#discussion_r288210167 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/

[GitHub] [flink] azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods

2019-05-28 Thread GitBox
azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods URL: https://github.com/apache/flink/pull/8529#discussion_r288212692 ## File path: flink-core/src/main/java/org/apache/flink/api/common/TaskInfo.j

[GitHub] [flink] azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods

2019-05-28 Thread GitBox
azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods URL: https://github.com/apache/flink/pull/8529#discussion_r288209939 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/

[GitHub] [flink] azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods

2019-05-28 Thread GitBox
azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods URL: https://github.com/apache/flink/pull/8529#discussion_r288223427 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/

[GitHub] [flink] azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods

2019-05-28 Thread GitBox
azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods URL: https://github.com/apache/flink/pull/8529#discussion_r288210019 ## File path: flink-streaming-java/src/main/java/org/apache/flink/streaming/

[GitHub] [flink] azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods

2019-05-28 Thread GitBox
azagrebin commented on a change in pull request #8529: [FLINK-12603][network] Refactor InputGate interface to remove unnecessary methods URL: https://github.com/apache/flink/pull/8529#discussion_r288218530 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/io/networ