Github user zhijiangW commented on a diff in the pull request:
https://github.com/apache/flink/pull/4509#discussion_r142142736
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
---
@@ -235,14 +240,15 @@ void releaseBuffer() {
ByteBuf write(ByteBufAllocator allocator) throws IOException {
checkNotNull(buffer, "No buffer instance to
serialize.");
- int length = 16 + 4 + 1 + 4 + buffer.getSize();
+ int length = 16 + 4 + 4 + 1 + 4 + buffer.getSize();
--- End diff --
I think the lengths for the corresponding fields can be seen clearly in the
below write method.
---
