Skip to content

ByteBufPrimitiveCodec is leaking native memory #795

New issue
New issue
Open
Open
ByteBufPrimitiveCodec is leaking native memory#795
@rixterd2

Description

@rixterd2
rixterd2
opened on Jan 30, 2026

Greetings,

We have discovered with the help of netty an issue described below.

"LEAK: ByteBuf.release() was not called before it's garbage-collected. See https://netty.io/wiki/reference-counted-objects.html for more information.
  Recent access records: 
  #1:
  io.netty.buffer.AdvancedLeakAwareByteBuf.writeBytes(AdvancedLeakAwareByteBuf.java:623)
  com.datastax.oss.driver.internal.core.protocol.ByteBufPrimitiveCodec.writeBytes(ByteBufPrimitiveCodec.java:203)
  com.datastax.oss.driver.internal.core.protocol.ByteBufPrimitiveCodec.writeBytes(ByteBufPrimitiveCodec.java:30)
  com.datastax.oss.protocol.internal.request.query.Values.writeValue(Values.java:71)
  com.datastax.oss.protocol.internal.request.query.Values.writePositionalValues(Values.java:34)
  com.datastax.oss.protocol.internal.request.query.QueryOptions$Codec.encode(QueryOptions.java:207)
  com.datastax.oss.protocol.internal.request.Execute$Codec.encode(Execute.java:69)
  com.datastax.oss.protocol.internal.FrameCodec.encodeBodyInto(FrameCodec.java:229)
  com.datastax.oss.protocol.internal.FrameCodec.encodeInto(FrameCodec.java:204)
  com.datastax.oss.protocol.internal.FrameCodec.encode(FrameCodec.java:129)
  com.datastax.oss.driver.internal.core.protocol.FrameEncoder.encode(FrameEncoder.java:43)
  com.datastax.oss.driver.internal.core.protocol.FrameEncoder.encode(FrameEncoder.java:28)
  io.netty.handler.codec.MessageToMessageEncoder.write(MessageToMessageEncoder.java:90)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:881)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  io.netty.handler.timeout.IdleStateHandler.write(IdleStateHandler.java:304)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:879)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  com.datastax.oss.driver.internal.core.channel.InFlightHandler.write(InFlightHandler.java:151)
  com.datastax.oss.driver.internal.core.channel.InFlightHandler.write(InFlightHandler.java:108)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:879)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  io.netty.channel.DefaultChannelPipeline.write(DefaultChannelPipeline.java:1015)
  io.netty.channel.AbstractChannel.write(AbstractChannel.java:301)
  com.datastax.oss.driver.internal.core.channel.DefaultWriteCoalescer$Flusher.runOnEventLoop(DefaultWriteCoalescer.java:100)
  io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)
  io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)
  io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)
  io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569)
  io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
  io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  java.base/java.lang.Thread.run(Thread.java:840)
  #2:
  io.netty.buffer.AdvancedLeakAwareByteBuf.writeShort(AdvancedLeakAwareByteBuf.java:551)
  com.datastax.oss.driver.internal.core.protocol.ByteBufPrimitiveCodec.writeUnsignedShort(ByteBufPrimitiveCodec.java:180)
  com.datastax.oss.driver.internal.core.protocol.ByteBufPrimitiveCodec.writeUnsignedShort(ByteBufPrimitiveCodec.java:30)
  com.datastax.oss.protocol.internal.request.query.QueryOptions$Codec.encode(QueryOptions.java:197)
  com.datastax.oss.protocol.internal.request.Execute$Codec.encode(Execute.java:69)
  com.datastax.oss.protocol.internal.FrameCodec.encodeBodyInto(FrameCodec.java:229)
  com.datastax.oss.protocol.internal.FrameCodec.encodeInto(FrameCodec.java:204)
  com.datastax.oss.protocol.internal.FrameCodec.encode(FrameCodec.java:129)
  com.datastax.oss.driver.internal.core.protocol.FrameEncoder.encode(FrameEncoder.java:43)
  com.datastax.oss.driver.internal.core.protocol.FrameEncoder.encode(FrameEncoder.java:28)
  io.netty.handler.codec.MessageToMessageEncoder.write(MessageToMessageEncoder.java:90)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:881)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  io.netty.handler.timeout.IdleStateHandler.write(IdleStateHandler.java:304)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:879)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  com.datastax.oss.driver.internal.core.channel.InFlightHandler.write(InFlightHandler.java:151)
  com.datastax.oss.driver.internal.core.channel.InFlightHandler.write(InFlightHandler.java:108)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:879)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  io.netty.channel.DefaultChannelPipeline.write(DefaultChannelPipeline.java:1015)
  io.netty.channel.AbstractChannel.write(AbstractChannel.java:301)
  com.datastax.oss.driver.internal.core.channel.DefaultWriteCoalescer$Flusher.runOnEventLoop(DefaultWriteCoalescer.java:100)
  io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)
  io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)
  io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)
  io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569)
  io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
  io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  java.base/java.lang.Thread.run(Thread.java:840)
  #3:
  io.netty.buffer.AdvancedLeakAwareByteBuf.writeBytes(AdvancedLeakAwareByteBuf.java:611)
  com.datastax.oss.driver.internal.core.protocol.ByteBufPrimitiveCodec.writeShortBytes(ByteBufPrimitiveCodec.java:220)
  com.datastax.oss.driver.internal.core.protocol.ByteBufPrimitiveCodec.writeShortBytes(ByteBufPrimitiveCodec.java:30)
  com.datastax.oss.protocol.internal.request.Execute$Codec.encode(Execute.java:65)
  com.datastax.oss.protocol.internal.FrameCodec.encodeBodyInto(FrameCodec.java:229)
  com.datastax.oss.protocol.internal.FrameCodec.encodeInto(FrameCodec.java:204)
  com.datastax.oss.protocol.internal.FrameCodec.encode(FrameCodec.java:129)
  com.datastax.oss.driver.internal.core.protocol.FrameEncoder.encode(FrameEncoder.java:43)
  com.datastax.oss.driver.internal.core.protocol.FrameEncoder.encode(FrameEncoder.java:28)
  io.netty.handler.codec.MessageToMessageEncoder.write(MessageToMessageEncoder.java:90)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:881)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  io.netty.handler.timeout.IdleStateHandler.write(IdleStateHandler.java:304)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:879)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  com.datastax.oss.driver.internal.core.channel.InFlightHandler.write(InFlightHandler.java:151)
  com.datastax.oss.driver.internal.core.channel.InFlightHandler.write(InFlightHandler.java:108)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:879)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  io.netty.channel.DefaultChannelPipeline.write(DefaultChannelPipeline.java:1015)
  io.netty.channel.AbstractChannel.write(AbstractChannel.java:301)
  com.datastax.oss.driver.internal.core.channel.DefaultWriteCoalescer$Flusher.runOnEventLoop(DefaultWriteCoalescer.java:100)
  io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)
  io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)
  io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)
  io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569)
  io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
  io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  java.base/java.lang.Thread.run(Thread.java:840)
  #4:
  io.netty.buffer.AdvancedLeakAwareByteBuf.writeInt(AdvancedLeakAwareByteBuf.java:563)
  com.datastax.oss.driver.internal.core.protocol.ByteBufPrimitiveCodec.writeInt(ByteBufPrimitiveCodec.java:163)
  com.datastax.oss.driver.internal.core.protocol.ByteBufPrimitiveCodec.writeInt(ByteBufPrimitiveCodec.java:30)
  com.datastax.oss.protocol.internal.FrameCodec.encodeHeaderInto(FrameCodec.java:222)
  com.datastax.oss.protocol.internal.FrameCodec.encodeInto(FrameCodec.java:203)
  com.datastax.oss.protocol.internal.FrameCodec.encode(FrameCodec.java:129)
  com.datastax.oss.driver.internal.core.protocol.FrameEncoder.encode(FrameEncoder.java:43)
  com.datastax.oss.driver.internal.core.protocol.FrameEncoder.encode(FrameEncoder.java:28)
  io.netty.handler.codec.MessageToMessageEncoder.write(MessageToMessageEncoder.java:90)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:881)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  io.netty.handler.timeout.IdleStateHandler.write(IdleStateHandler.java:304)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:879)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  com.datastax.oss.driver.internal.core.channel.InFlightHandler.write(InFlightHandler.java:151)
  com.datastax.oss.driver.internal.core.channel.InFlightHandler.write(InFlightHandler.java:108)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:879)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  io.netty.channel.DefaultChannelPipeline.write(DefaultChannelPipeline.java:1015)
  io.netty.channel.AbstractChannel.write(AbstractChannel.java:301)
  com.datastax.oss.driver.internal.core.channel.DefaultWriteCoalescer$Flusher.runOnEventLoop(DefaultWriteCoalescer.java:100)
  io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)
  io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)
  io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)
  io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569)
  io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
  io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  java.base/java.lang.Thread.run(Thread.java:840)
  #5:
  io.netty.buffer.AdvancedLeakAwareByteBuf.writeByte(AdvancedLeakAwareByteBuf.java:545)
  com.datastax.oss.driver.internal.core.protocol.ByteBufPrimitiveCodec.writeByte(ByteBufPrimitiveCodec.java:158)
  com.datastax.oss.driver.internal.core.protocol.ByteBufPrimitiveCodec.writeByte(ByteBufPrimitiveCodec.java:30)
  com.datastax.oss.protocol.internal.FrameCodec.encodeHeaderInto(FrameCodec.java:221)
  com.datastax.oss.protocol.internal.FrameCodec.encodeInto(FrameCodec.java:203)
  com.datastax.oss.protocol.internal.FrameCodec.encode(FrameCodec.java:129)
  com.datastax.oss.driver.internal.core.protocol.FrameEncoder.encode(FrameEncoder.java:43)
  com.datastax.oss.driver.internal.core.protocol.FrameEncoder.encode(FrameEncoder.java:28)
  io.netty.handler.codec.MessageToMessageEncoder.write(MessageToMessageEncoder.java:90)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:881)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  io.netty.handler.timeout.IdleStateHandler.write(IdleStateHandler.java:304)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:879)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  com.datastax.oss.driver.internal.core.channel.InFlightHandler.write(InFlightHandler.java:151)
  com.datastax.oss.driver.internal.core.channel.InFlightHandler.write(InFlightHandler.java:108)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:879)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  io.netty.channel.DefaultChannelPipeline.write(DefaultChannelPipeline.java:1015)
  io.netty.channel.AbstractChannel.write(AbstractChannel.java:301)
  com.datastax.oss.driver.internal.core.channel.DefaultWriteCoalescer$Flusher.runOnEventLoop(DefaultWriteCoalescer.java:100)
  io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)
  io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)
  io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)
  io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569)
  io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
  io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  java.base/java.lang.Thread.run(Thread.java:840)
  #6:
  io.netty.buffer.AdvancedLeakAwareByteBuf.writeShort(AdvancedLeakAwareByteBuf.java:551)
  com.datastax.oss.driver.internal.core.protocol.ByteBufPrimitiveCodec.writeUnsignedShort(ByteBufPrimitiveCodec.java:180)
  com.datastax.oss.driver.internal.core.protocol.ByteBufPrimitiveCodec.writeUnsignedShort(ByteBufPrimitiveCodec.java:30)
  com.datastax.oss.protocol.internal.FrameCodec.encodeHeaderInto(FrameCodec.java:218)
  com.datastax.oss.protocol.internal.FrameCodec.encodeInto(FrameCodec.java:203)
  com.datastax.oss.protocol.internal.FrameCodec.encode(FrameCodec.java:129)
  com.datastax.oss.driver.internal.core.protocol.FrameEncoder.encode(FrameEncoder.java:43)
  com.datastax.oss.driver.internal.core.protocol.FrameEncoder.encode(FrameEncoder.java:28)
  io.netty.handler.codec.MessageToMessageEncoder.write(MessageToMessageEncoder.java:90)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:881)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  io.netty.handler.timeout.IdleStateHandler.write(IdleStateHandler.java:304)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:879)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  com.datastax.oss.driver.internal.core.channel.InFlightHandler.write(InFlightHandler.java:151)
  com.datastax.oss.driver.internal.core.channel.InFlightHandler.write(InFlightHandler.java:108)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:879)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  io.netty.channel.DefaultChannelPipeline.write(DefaultChannelPipeline.java:1015)
  io.netty.channel.AbstractChannel.write(AbstractChannel.java:301)
  com.datastax.oss.driver.internal.core.channel.DefaultWriteCoalescer$Flusher.runOnEventLoop(DefaultWriteCoalescer.java:100)
  io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)
  io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)
  io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)
  io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569)
  io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
  io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  java.base/java.lang.Thread.run(Thread.java:840)
  #7:
  io.netty.buffer.AdvancedLeakAwareByteBuf.writeByte(AdvancedLeakAwareByteBuf.java:545)
  com.datastax.oss.driver.internal.core.protocol.ByteBufPrimitiveCodec.writeByte(ByteBufPrimitiveCodec.java:158)
  com.datastax.oss.driver.internal.core.protocol.ByteBufPrimitiveCodec.writeByte(ByteBufPrimitiveCodec.java:30)
  com.datastax.oss.protocol.internal.FrameCodec.encodeHeaderInto(FrameCodec.java:217)
  com.datastax.oss.protocol.internal.FrameCodec.encodeInto(FrameCodec.java:203)
  com.datastax.oss.protocol.internal.FrameCodec.encode(FrameCodec.java:129)
  com.datastax.oss.driver.internal.core.protocol.FrameEncoder.encode(FrameEncoder.java:43)
  com.datastax.oss.driver.internal.core.protocol.FrameEncoder.encode(FrameEncoder.java:28)
  io.netty.handler.codec.MessageToMessageEncoder.write(MessageToMessageEncoder.java:90)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:881)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  io.netty.handler.timeout.IdleStateHandler.write(IdleStateHandler.java:304)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:879)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  com.datastax.oss.driver.internal.core.channel.InFlightHandler.write(InFlightHandler.java:151)
  com.datastax.oss.driver.internal.core.channel.InFlightHandler.write(InFlightHandler.java:108)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:879)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  io.netty.channel.DefaultChannelPipeline.write(DefaultChannelPipeline.java:1015)
  io.netty.channel.AbstractChannel.write(AbstractChannel.java:301)
  com.datastax.oss.driver.internal.core.channel.DefaultWriteCoalescer$Flusher.runOnEventLoop(DefaultWriteCoalescer.java:100)
  io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)
  io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)
  io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)
  io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569)
  io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
  io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  java.base/java.lang.Thread.run(Thread.java:840)
  #8:
  io.netty.buffer.AdvancedLeakAwareByteBuf.writeByte(AdvancedLeakAwareByteBuf.java:545)
  com.datastax.oss.driver.internal.core.protocol.ByteBufPrimitiveCodec.writeByte(ByteBufPrimitiveCodec.java:158)
  com.datastax.oss.driver.internal.core.protocol.ByteBufPrimitiveCodec.writeByte(ByteBufPrimitiveCodec.java:30)
  com.datastax.oss.protocol.internal.FrameCodec.encodeHeaderInto(FrameCodec.java:216)
  com.datastax.oss.protocol.internal.FrameCodec.encodeInto(FrameCodec.java:203)
  com.datastax.oss.protocol.internal.FrameCodec.encode(FrameCodec.java:129)
  com.datastax.oss.driver.internal.core.protocol.FrameEncoder.encode(FrameEncoder.java:43)
  com.datastax.oss.driver.internal.core.protocol.FrameEncoder.encode(FrameEncoder.java:28)
  io.netty.handler.codec.MessageToMessageEncoder.write(MessageToMessageEncoder.java:90)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:881)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  io.netty.handler.timeout.IdleStateHandler.write(IdleStateHandler.java:304)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:879)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  com.datastax.oss.driver.internal.core.channel.InFlightHandler.write(InFlightHandler.java:151)
  com.datastax.oss.driver.internal.core.channel.InFlightHandler.write(InFlightHandler.java:108)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:879)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  io.netty.channel.DefaultChannelPipeline.write(DefaultChannelPipeline.java:1015)
  io.netty.channel.AbstractChannel.write(AbstractChannel.java:301)
  com.datastax.oss.driver.internal.core.channel.DefaultWriteCoalescer$Flusher.runOnEventLoop(DefaultWriteCoalescer.java:100)
  io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)
  io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)
  io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)
  io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569)
  io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
  io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  java.base/java.lang.Thread.run(Thread.java:840)
  Created at:
  io.netty.buffer.PooledByteBufAllocator.newDirectBuffer(PooledByteBufAllocator.java:403)
  io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:188)
  io.netty.buffer.AbstractByteBufAllocator.ioBuffer(AbstractByteBufAllocator.java:148)
  com.datastax.oss.driver.internal.core.protocol.ByteBufPrimitiveCodec.allocate(ByteBufPrimitiveCodec.java:41)
  com.datastax.oss.driver.internal.core.protocol.ByteBufPrimitiveCodec.allocate(ByteBufPrimitiveCodec.java:30)
  com.datastax.oss.protocol.internal.FrameCodec.encode(FrameCodec.java:128)
  com.datastax.oss.driver.internal.core.protocol.FrameEncoder.encode(FrameEncoder.java:43)
  com.datastax.oss.driver.internal.core.protocol.FrameEncoder.encode(FrameEncoder.java:28)
  io.netty.handler.codec.MessageToMessageEncoder.write(MessageToMessageEncoder.java:90)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:881)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  io.netty.handler.timeout.IdleStateHandler.write(IdleStateHandler.java:304)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:879)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  com.datastax.oss.driver.internal.core.channel.InFlightHandler.write(InFlightHandler.java:151)
  com.datastax.oss.driver.internal.core.channel.InFlightHandler.write(InFlightHandler.java:108)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:879)
  io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968)
  io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)
  io.netty.channel.DefaultChannelPipeline.write(DefaultChannelPipeline.java:1015)
  io.netty.channel.AbstractChannel.write(AbstractChannel.java:301)
  com.datastax.oss.driver.internal.core.channel.DefaultWriteCoalescer$Flusher.runOnEventLoop(DefaultWriteCoalescer.java:100)
  io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)
  io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)
  io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)
  io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569)
  io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
  io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  java.base/java.lang.Thread.run(Thread.java:840)
  : 8 leak records were discarded because the leak record count is targeted to 4. Use system property io.netty.leakDetection.targetRecords to increase the limit."

Regards,
Vladimir

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions