File tree Expand file tree Collapse file tree 1 file changed +2
-5
lines changed
common/network-common/src/main/java/org/apache/spark/network/util Expand file tree Collapse file tree 1 file changed +2
-5
lines changed Original file line number Diff line number Diff line change @@ -140,15 +140,12 @@ private ByteBuf decodeNext() throws Exception {
140140 }
141141
142142 // Otherwise, create a composite buffer.
143- CompositeByteBuf frame = buffers .getFirst ().alloc ().compositeBuffer ();
144- LinkedList <ByteBuf > frameBuffers = new LinkedList <>();
143+ CompositeByteBuf frame = buffers .getFirst ().alloc ().compositeBuffer (Integer .MAX_VALUE );
145144 while (remaining > 0 ) {
146145 ByteBuf next = nextBufferForFrame (remaining );
147- frameBuffers .add (next );
148146 remaining -= next .readableBytes ();
147+ frame .addComponent (next ).writerIndex (frame .writerIndex () + next .readableBytes ());
149148 }
150- frame .addComponents (frameBuffers ).writerIndex (frame .writerIndex () + (int ) frameSize );
151- frameBuffers .clear ();
152149 assert remaining == 0 ;
153150 return frame ;
154151 }
You can’t perform that action at this time.
0 commit comments