[GitHub] flink pull request #6272: [FLINK-9755][network] forward exceptions in Remote...

[pnowojski]

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

    https://github.com/apache/flink/pull/6272#discussion_r201743330
  
    --- Diff: 
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/buffer/LocalBufferPool.java
 ---
    @@ -258,12 +258,12 @@ private MemorySegment requestMemorySegment(boolean 
isBlocking) throws Interrupte
        @Override
        public void recycle(MemorySegment segment) {
                BufferListener listener;
    +           boolean needMoreBuffers = false;
    --- End diff --
    
    why did you move this declaration up here? Inline it with `needMoreBuffers 
= listener.notifyBufferAvailable(...)`?


---