Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5570
---
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5570#discussion_r170911325
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/io/network/netty/NettyMessage.java
---
@@ -188,58 +186,83 @@ public void
Github user pnowojski commented on a diff in the pull request:
https://github.com/apache/flink/pull/5570#discussion_r170911555
--- Diff:
flink-runtime/src/test/java/org/apache/flink/runtime/io/network/netty/NettyMessageSerializationTest.java
---
@@ -44,10 +44,11 @@
*/
GitHub user NicoK opened a pull request:
https://github.com/apache/flink/pull/5570
[FLINK-8768][network] Let NettyMessageDecoder inherit from
LengthFieldBasedFrameDecoder
## What is the purpose of the change
Instead of being two steps in the channel pipeline,
