Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/5572#discussion_r170585362
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/iterative/task/IterationHeadTask.java
---
@@ -447,6 +447,8 @@ private void sendEndOfSuperstepToAllIterationOutputs()
throws IOException, Inter
for (RecordWriter<?> eventualOutput : this.eventualOutputs) {
eventualOutput.broadcastEvent(EndOfSuperstepEvent.INSTANCE);
+ eventualOutput.clearBuffers();
+ eventualOutput.flushAll();
--- End diff --
let's remove those two - they should be unnecessary
---
