From c2f9ed10776842ffe0746fcc89b157675fa6c455 Mon Sep 17 00:00:00 2001 From: Nihar Sheth Date: Tue, 14 Aug 2018 15:49:41 -0700 Subject: [PATCH] netty defaults to using current buffers specified by the preferred buffer type instead of immediately opening a pool of onheap memory for headers --- .../java/org/apache/spark/network/protocol/MessageEncoder.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/common/network-common/src/main/java/org/apache/spark/network/protocol/MessageEncoder.java b/common/network-common/src/main/java/org/apache/spark/network/protocol/MessageEncoder.java index 997f74e1a21b4..06dc447309dd9 100644 --- a/common/network-common/src/main/java/org/apache/spark/network/protocol/MessageEncoder.java +++ b/common/network-common/src/main/java/org/apache/spark/network/protocol/MessageEncoder.java @@ -79,7 +79,7 @@ public void encode(ChannelHandlerContext ctx, Message in, List out) thro // sent. int headerLength = 8 + msgType.encodedLength() + in.encodedLength(); long frameLength = headerLength + (isBodyInFrame ? bodyLength : 0); - ByteBuf header = ctx.alloc().heapBuffer(headerLength); + ByteBuf header = ctx.alloc().buffer(headerLength); header.writeLong(frameLength); msgType.encode(header); in.encode(header);