You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Netty versions >= 4.0.28.Final contain an improvement by Netty, which slices
a Netty buffer instead of doing a memory copy (netty/netty#3704)
in the LengthFieldBasedFrameDecoder. In some situations, this interacts badly
with our Netty pipeline leading to OutOfMemory error.
To reproduce, run batch WordCount with a range partitioner and reasonably large
data.
asfgit
pushed a commit
to apache/flink
that referenced
this issue
Jan 13, 2016
Netty versions >= 4.0.28.Final contain an improvement by Netty, which slices
a Netty buffer instead of doing a memory copy (netty/netty#3704)
in the LengthFieldBasedFrameDecoder. In some situations, this interacts badly
with our Netty pipeline leading to OutOfMemory error.
To reproduce, run batch WordCount with a range partitioner and reasonably large
data.
Motivation:
We are currently doing a memory cop to extract the frame in LengthFieldBasedFrameDecoder which can be eliminated.
Modifications:
Use buffer.slice(...).retain() to eliminate the memory copy.
Result:
Better performance.
The text was updated successfully, but these errors were encountered: