Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5572#discussion_r170873853
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionView.java
---
@@ -187,7 +185,6 @@ public BufferAndBacklog getNextBuffer() throws
IOException, InterruptedException
@Override
public void notifyDataAvailable() {
- // We do the availability listener notification one by one
--- End diff --
This was the remanent of a different approach to fix the problem. Reverted.
---
