[GitHub] flink pull request #5105: [FLINK-8178][network] Introduce not threadsafe wri...

[NicoK]

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

    https://github.com/apache/flink/pull/5105#discussion_r156414085
  
    --- Diff: 
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/api/writer/RecordWriter.java
 ---
    @@ -129,8 +130,8 @@ private void sendToTarget(T record, int targetChannel) 
throws IOException, Inter
                                                break;
                                        }
                                } else {
    -                                   buffer = 
targetPartition.getBufferProvider().requestBufferBlocking();
    -                                   result = 
serializer.setNextBuffer(buffer);
    +                                   BufferBuilder bufferBuilder = 
targetPartition.getBufferProvider().requestBufferBuilderBlocking();
    --- End diff --
    
    can you break this long line up?


---