[GitHub] flink pull request #4559: [FLINK-7468][network] Implement sender backlog log...

[zhijiangW]

Github user zhijiangW commented on a diff in the pull request:

    https://github.com/apache/flink/pull/4559#discussion_r152193809
  
    --- Diff: 
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionView.java
 ---
    @@ -145,6 +145,10 @@ public Buffer getNextBuffer() throws IOException, 
InterruptedException {
                                        listener.notifyBuffersAvailable(1);
                                }
     
    +                           if (current.isBuffer()) {
    --- End diff --
    
    That is a good idea, and I already addressed this issue as you suggested.


---