Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5710
---
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/5710#discussion_r175425893
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/BufferBuilderAndConsumerTest.java
---
@@ -202,22 +202,30 @@ private static
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/5710#discussion_r175414806
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferBuilder.java
---
@@ -99,10 +99,11 @@ public void commit() {
*
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/5710#discussion_r175404351
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferBuilder.java
---
@@ -99,10 +99,11 @@ public void commit() {
*
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/5710#discussion_r175402536
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/buffer/BufferBuilderAndConsumerTest.java
---
@@ -81,6 +81,24 @@ public void
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5710#discussion_r175398935
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferBuilder.java
---
@@ -99,10 +99,11 @@ public void commit() {
Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/5710#discussion_r175363048
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/BufferBuilder.java
---
@@ -99,10 +99,11 @@ public void commit() {
*
GitHub user pnowojski opened a pull request:
https://github.com/apache/flink/pull/5710
[FLINK-8948][runtime] Fix IllegalStateException when closing StreamTask
All methods in
org.apache.flink.streaming.runtime.tasks.OperatorChain#releaseOutputs shouldn't
throw any exceptions and
