Github user NicoK commented on a diff in the pull request:
https://github.com/apache/flink/pull/5261#discussion_r160349800
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/PipelinedSubpartition.java
---
@@ -52,6 +55,10 @@
/** Flag indicating whether the subpartition has been released. */
private volatile boolean isReleased;
+ /** The number of non-event buffers currently in this subpartition */
--- End diff --
alright - created a fixup for FLINK-7468 here---
