Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/4559#discussion_r152008524
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartition.java
---
@@ -246,9 +246,9 @@ public int unsynchronizedGetNumberOfQueuedBuffers() {
@Override
public String toString() {
return String.format("SpillableSubpartition [%d number of
buffers (%d bytes)," +
- "finished? %s, read view? %s,
spilled? %s]",
- getTotalNumberOfBuffers(),
getTotalNumberOfBytes(), isFinished, readView != null,
- spillWriter != null);
+ "%d backlog, finished? %s, read view? %s,
spilled? %s]",
+ getTotalNumberOfBuffers(), getTotalNumberOfBytes(),
+ backlog, isFinished, readView != null, spillWriter !=
null);
--- End diff --
`getBacklog`?
---
