[GitHub] flink pull request #4499: [FLINK-7394][core] Manage exclusive buffers in Rem...

2017-10-10 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/4499 ---

[GitHub] flink pull request #4499: [FLINK-7394][core] Manage exclusive buffers in Rem...

2017-09-25 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4499#discussion_r140831859 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java --- @@ -281,6 +286,73 @@ public void

[GitHub] flink pull request #4499: [FLINK-7394][core] Manage exclusive buffers in Rem...

2017-09-25 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4499#discussion_r140833417 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannelTest.java --- @@ -281,6 +286,73 @@ public void

[GitHub] flink pull request #4499: [FLINK-7394][core] Manage exclusive buffers in Rem...

2017-09-25 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4499#discussion_r140831302 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -183,18 +214,40 @@ void

[GitHub] flink pull request #4499: [FLINK-7394][core] Manage exclusive buffers in Rem...

2017-09-25 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4499#discussion_r140829015 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -215,6 +269,48 @@ public String

[GitHub] flink pull request #4499: [FLINK-7394][core] Manage exclusive buffers in Rem...

2017-09-25 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4499#discussion_r140822508 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -183,18 +214,40 @@ void

[GitHub] flink pull request #4499: [FLINK-7394][core] Manage exclusive buffers in Rem...

2017-09-25 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4499#discussion_r140811033 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -100,7 +122,16 @@ public

[GitHub] flink pull request #4499: [FLINK-7394][core] Manage exclusive buffers in Rem...

2017-09-25 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4499#discussion_r140809272 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -70,6 +78,15 @@ */

[GitHub] flink pull request #4499: [FLINK-7394][core] Manage exclusive buffers in Rem...

2017-09-25 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4499#discussion_r140810853 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -99,8 +114,24 @@ public

[GitHub] flink pull request #4499: [FLINK-7394][core] Manage exclusive buffers in Rem...

2017-09-25 Thread NicoK
Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4499#discussion_r140821090 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/consumer/RemoteInputChannel.java --- @@ -183,18 +214,40 @@ void