Github user zhijiangW commented on a diff in the pull request: https://github.com/apache/flink/pull/4552#discussion_r161450876 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionView.java --- @@ -199,6 +199,19 @@ public boolean isReleased() { } } + @Override + public boolean nextBufferIsEvent() { + if (nextBuffer != null) { + return !nextBuffer.isBuffer(); + } --- End diff -- agree with integration
---