Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6238
---
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6238#discussion_r199832400
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java
---
@@ -151,7 +151,12 @@ public void
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6238#discussion_r199813070
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPoolTest.java
---
@@ -396,4 +398,48 @@ public void go()
Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/6238#discussion_r199811207
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java
---
@@ -151,7 +151,12 @@ public void
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/6238#discussion_r199702444
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java
---
@@ -147,7 +151,12 @@ public void
Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/6238#discussion_r199676237
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/NetworkBufferPool.java
---
@@ -147,7 +151,12 @@ public void
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/6238
[FLINK-9636][network] fix inconsistency with failed buffer redistribution
## What is the purpose of the change
If an exception is thrown in `NetworkBufferPool#requestMemorySegments()`'s
