Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5261#discussion_r160178046
--- 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 --
nit: Should also end with a period.---
