apache/celeborn
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[ISSUE-288] fix netty memory leak(#310)

Browse Source
This commit is contained in:
Keyong Zhou 2022-08-12 00:49:42 +08:00 committed by GitHub
parent d19b475500
commit 46cbe4fb04
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
common/src/main/java/com/aliyun/emr/rss/common/network/protocol/ChunkFetchSuccess.java
View File

@ -64,8 +64,7 @@ public final class ChunkFetchSuccess extends ResponseMessage {
public static ChunkFetchSuccess decode(ByteBuf buf, boolean decodeBody) {
StreamChunkSlice streamChunkSlice = StreamChunkSlice.decode(buf);
if (decodeBody) {
buf.retain();
NettyManagedBuffer managedBuf = new NettyManagedBuffer(buf.duplicate());
NettyManagedBuffer managedBuf = new NettyManagedBuffer(buf);
return new ChunkFetchSuccess(streamChunkSlice, managedBuf);
} else {
return new ChunkFetchSuccess(streamChunkSlice, NettyManagedBuffer.EmptyBuffer);

3
common/src/main/java/com/aliyun/emr/rss/common/network/util/TransportFrameDecoder.java
View File

@ -69,6 +69,9 @@ public class TransportFrameDecoder extends ChannelInboundHandlerAdapter implemen
break;
}
Message msg = Message.decode(curType, frame);
if (msg.body() == null) {
frame.release();
}
ctx.fireChannelRead(msg);
clear();
}