It looks like we need to call release() from some place(s) where we don't currently. HBase had the same issues [1]. We use this in the StandardMapCacheServer and ListenBeats, are you using either, neither, or both?
Regards, Matt [1] https://github.com/netty/netty/issues/12549 On Tue, Dec 26, 2023 at 8:53 AM Rafael Fracasso <rafaelfraca...@gmail.com> wrote: > > Hi, > > sometimes I have these ResourceLeakDetector exceptions on my nifi-app.log, > you guys know the reason this exception was raised and how I avoid them to > happen? > > Thanks > > Rafael > > > > 2023-12-26 09:02:15,353 ERROR [nioEventLoopGroup-3-6] > io.netty.util.ResourceLeakDetector 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: > > Created at: > > io.netty.buffer.PooledByteBufAllocator.newDirectBuffer(PooledByteBufAllocator.java:403) > > io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:188) > > io.netty.buffer.AbstractByteBufAllocator.buffer(AbstractByteBufAllocator.java:124) > > io.netty.buffer.AbstractByteBuf.readBytes(AbstractByteBuf.java:871) > > org.apache.nifi.distributed.cache.server.codec.CacheRequestDecoder.readHeader(CacheRequestDecoder.java:238) > > org.apache.nifi.distributed.cache.server.codec.CacheRequestDecoder.decode(CacheRequestDecoder.java:80) > > io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:519) > > io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:458) > > io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:280) > > io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) > > io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) > > io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) > > io.netty.handler.timeout.IdleStateHandler.channelRead(IdleStateHandler.java:286) > > io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) > > io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) > > io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) > > io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1410) > > io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) > > io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) > > io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:919) > > io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166) > > io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:788) > > io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:724) > > io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:650) > > io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562) > > 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:833)
