Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4559#discussion_r152010406
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/ResultSubpartition.java
---
@@ -41,12 +41,19 @@
/** The total number of bytes (both data and event buffers) */
private long totalNumberOfBytes;
+ /** The number of non-event buffers currently in this subpartition */
+ protected int backlog;
--- End diff --
rename `backlog` to
`buffersInBacklog`/`accumulatedBuffers`/`backloggedBuffers`?
---
