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?
---
