LEAK: ByteBuf.release() was not called before it's garbage-collected

XMLWordPrintableJSON

    • Type: Bug
    • Resolution: Duplicate
    • Priority: Unknown
    • None
    • Affects Version/s: 5.6.2
    • Component/s: None
    • Java Drivers
    • Hide

      1. What would you like to communicate to the user about this feature?
      2. Would you like the user to see examples of the syntax and/or executable code and its output?
      3. Which versions of the driver/connector does this apply to?

      Show
      1. What would you like to communicate to the user about this feature? 2. Would you like the user to see examples of the syntax and/or executable code and its output? 3. Which versions of the driver/connector does this apply to?
    • None
    • None
    • None
    • None
    • None
    • None

      Hello,

      after upgrading our applications to Spring Boot 4 we see the following error/warning in our logs many times:

       

      LEAK: ByteBuf.release() was not called before it's garbage-collected. See https://netty.io/wiki/reference-counted-objects.html for more information.

      We use mongodb-driver-core 5.6.2 via spring-data-mongodb 5.0.1.

      Do you have an idea what could be the reason for this?

      Here a complete stacktrace:

      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:
      com.mongodb.internal.connection.netty.NettyByteBuf.release(NettyByteBuf.java:285)
      com.mongodb.internal.connection.ByteBufferBsonOutput.close(ByteBufferBsonOutput.java:313)
      com.mongodb.internal.connection.InternalStreamConnection.lambda$sendCommandMessageAsync$10(InternalStreamConnection.java:600)
      com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:47)
      com.mongodb.internal.async.AsyncSupplier.lambda$finish$0(AsyncSupplier.java:73)
      com.mongodb.internal.async.AsyncSupplier.lambda$finish$0(AsyncSupplier.java:73)
      com.mongodb.internal.async.AsyncSupplier.lambda$finish$0(AsyncSupplier.java:73)
      com.mongodb.internal.async.SingleResultCallback.complete(SingleResultCallback.java:67)
      com.mongodb.internal.async.AsyncSupplier.lambda$onErrorIf$7(AsyncSupplier.java:173)
      com.mongodb.internal.async.AsyncSupplier.lambda$finish$0(AsyncSupplier.java:73)
      com.mongodb.internal.async.AsyncSupplier.lambda$finish$0(AsyncSupplier.java:73)
      com.mongodb.internal.async.SingleResultCallback$1.completed(SingleResultCallback.java:49)
      com.mongodb.internal.connection.netty.NettyStream.lambda$writeAsync$1(NettyStream.java:262)
      io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:604)
      io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:571)
      io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:506)
      io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:650)
      io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:639)
      io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:119)
      io.netty.util.internal.PromiseNotificationUtil.trySuccess(PromiseNotificationUtil.java:48)
      io.netty.channel.DelegatingChannelPromiseNotifier.operationComplete(DelegatingChannelPromiseNotifier.java:52)
      io.netty.channel.DelegatingChannelPromiseNotifier.operationComplete(DelegatingChannelPromiseNotifier.java:31)
      io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:604)
      io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:571)
      io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:506)
      io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:650)
      io.netty.util.concurrent.DefaultPromise.setSuccess0(DefaultPromise.java:639)
      io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:119)
      io.netty.util.internal.PromiseNotificationUtil.trySuccess(PromiseNotificationUtil.java:48)
      io.netty.channel.ChannelOutboundBuffer.safeSuccess(ChannelOutboundBuffer.java:747)
      io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:302)
      io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:382)
      io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:414)
      io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:802)
      io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:404)
      io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:766)
      io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1391)
      io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:789)
      io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:775)
      io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:761)
      io.netty.handler.ssl.SslHandler.forceFlush(SslHandler.java:2325)
      io.netty.handler.ssl.SslHandler.wrapAndFlush(SslHandler.java:848)
      io.netty.handler.ssl.SslHandler.flush(SslHandler.java:825)
      io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:795)
      io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:835)
      io.netty.channel.AbstractChannelHandlerContext$WriteTask.run(AbstractChannelHandlerContext.java:1136)
      io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98)
      io.netty.util.concurrent.PromiseTask.run(PromiseTask.java:106)
      io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:148)
      io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:141)
      io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:535)
      io.netty.channel.SingleThreadIoEventLoop.run(SingleThreadIoEventLoop.java:201)
      io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:1195)
      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:1474)
      #2:
      io.netty.buffer.AdvancedLeakAwareByteBuf.setInt(AdvancedLeakAwareByteBuf.java:305)
      com.mongodb.internal.connection.netty.NettyByteBuf.putInt(NettyByteBuf.java:100)
      com.mongodb.internal.connection.ByteBufferBsonOutput.writeInt32(ByteBufferBsonOutput.java:121)
      org.bson.BsonBinaryWriter.backpatchSize(BsonBinaryWriter.java:447)
      org.bson.BsonBinaryWriter.doWriteEndDocument(BsonBinaryWriter.java:160)
      org.bson.AbstractBsonWriter.writeEndDocument(AbstractBsonWriter.java:308)
      org.bson.codecs.BsonDocumentCodec.encode(BsonDocumentCodec.java:116)
      org.bson.codecs.BsonDocumentCodec.encode(BsonDocumentCodec.java:39)
      com.mongodb.internal.connection.BsonWriterHelper.encodeUsingRegistry(BsonWriterHelper.java:186)
      com.mongodb.internal.connection.CommandMessage.writeCommand(CommandMessage.java:428)
      com.mongodb.internal.connection.CommandMessage.writeOpMsg(CommandMessage.java:246)
      com.mongodb.internal.connection.CommandMessage.encodeMessageBody(CommandMessage.java:234)
      com.mongodb.internal.connection.RequestMessage.encode(RequestMessage.java:95)
      com.mongodb.internal.connection.CommandMessage.encode(CommandMessage.java:73)
      com.mongodb.internal.connection.InternalStreamConnection.sendAndReceiveAsyncInternal(InternalStreamConnection.java:555)
      com.mongodb.internal.connection.InternalStreamConnection.lambda$sendAndReceiveAsync$1(InternalStreamConnection.java:392)
      com.mongodb.internal.async.AsyncSupplier.finish(AsyncSupplier.java:68)
      com.mongodb.internal.async.AsyncSupplier.getAsync(AsyncSupplier.java:49)
      com.mongodb.internal.connection.InternalStreamConnection.lambda$sendAndReceiveAsync$2(InternalStreamConnection.java:395)
      com.mongodb.internal.async.AsyncSupplier.finish(AsyncSupplier.java:68)
      com.mongodb.internal.async.AsyncRunnable.lambda$thenSupply$7(AsyncRunnable.java:218)
      com.mongodb.internal.async.SingleResultCallback.complete(SingleResultCallback.java:63)
      com.mongodb.internal.async.AsyncRunnable.lambda$beginAsync$0(AsyncRunnable.java:123)
      com.mongodb.internal.async.AsyncRunnable.lambda$thenSupply$8(AsyncRunnable.java:216)
      com.mongodb.internal.async.AsyncSupplier.finish(AsyncSupplier.java:68)
      com.mongodb.internal.async.AsyncSupplier.lambda$onErrorIf$8(AsyncSupplier.java:171)
      com.mongodb.internal.async.AsyncSupplier.finish(AsyncSupplier.java:68)
      com.mongodb.internal.connection.InternalStreamConnection.sendAndReceiveAsync(InternalStreamConnection.java:398)
      com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceiveAsync(UsageTrackingInternalConnection.java:141)
      com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceiveAsync(DefaultConnectionPool.java:782)
      com.mongodb.internal.connection.CommandProtocolImpl.executeAsync(CommandProtocolImpl.java:66)
      com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.executeAsync(DefaultServer.java:230)
      com.mongodb.internal.connection.DefaultServerConnection.executeProtocolAsync(DefaultServerConnection.java:119)
      com.mongodb.internal.connection.DefaultServerConnection.commandAsync(DefaultServerConnection.java:100)
      com.mongodb.internal.connection.DefaultServerConnection.commandAsync(DefaultServerConnection.java:92)
      com.mongodb.internal.connection.DefaultServer$AsyncOperationCountTrackingConnection.commandAsync(DefaultServer.java:359)
      com.mongodb.internal.operation.AsyncOperationHelper.lambda$executeRetryableWriteAsync$12(AsyncOperationHelper.java:286)
      com.mongodb.internal.operation.AsyncOperationHelper.lambda$withAsyncSourceAndConnection$0(AsyncOperationHelper.java:121)
      com.mongodb.internal.operation.AsyncOperationHelper.lambda$withAsyncSuppliedResource$2(AsyncOperationHelper.java:138)
      com.mongodb.internal.async.function.AsyncCallbackSupplier.lambda$whenComplete$2(AsyncCallbackSupplier.java:97)
      com.mongodb.internal.operation.AsyncOperationHelper.lambda$withAsyncSuppliedResource$3(AsyncOperationHelper.java:139)
      com.mongodb.internal.connection.DefaultServer.lambda$getConnectionAsync$0(DefaultServer.java:127)
      datadog.trace.instrumentation.mongo.CallbackWrapper.onResult(CallbackWrapper.java:31)
      com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:47)
      com.mongodb.internal.connection.DefaultConnectionPool.lambda$getAsync$0(DefaultConnectionPool.java:219)
      com.mongodb.internal.connection.DefaultConnectionPool.lambda$getAsync$1(DefaultConnectionPool.java:242)
      com.mongodb.internal.connection.DefaultConnectionPool$Task.doComplete(DefaultConnectionPool.java:1433)
      com.mongodb.internal.connection.DefaultConnectionPool$Task.execute(DefaultConnectionPool.java:1419)
      com.mongodb.internal.connection.DefaultConnectionPool$AsyncWorkManager.lambda$workerRun$4(DefaultConnectionPool.java:1356)
      com.mongodb.internal.time.Timeout.lambda$run$9(Timeout.java:200)
      com.mongodb.internal.time.TimePoint.checkedCall(TimePoint.java:101)
      com.mongodb.internal.time.Timeout.call(Timeout.java:176)
      com.mongodb.internal.time.Timeout.run(Timeout.java:196)
      com.mongodb.internal.connection.DefaultConnectionPool$AsyncWorkManager.workerRun(DefaultConnectionPool.java:1354)
      com.mongodb.internal.connection.DefaultConnectionPool$AsyncWorkManager.runAndLogUncaught(DefaultConnectionPool.java:1383)
      com.mongodb.internal.connection.DefaultConnectionPool$AsyncWorkManager.lambda$initUnlessClosed$1(DefaultConnectionPool.java:1324)
      java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:545)
      java.base/java.util.concurrent.FutureTask.run(FutureTask.java:328)
      java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1090)
      java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:614)
      java.base/java.lang.Thread.run(Thread.java:1474)
      #3:
      ... (logs omitted because of character limit)
      #10:
      io.netty.buffer.AdvancedLeakAwareByteBuf.writeInt(AdvancedLeakAwareByteBuf.java:569)
      com.mongodb.internal.connection.netty.NettyByteBuf.putInt(NettyByteBuf.java:94)
      com.mongodb.internal.connection.ByteBufferBsonOutput.writeInt32(ByteBufferBsonOutput.java:93)
      com.mongodb.internal.connection.RequestMessage.writeMessagePrologue(RequestMessage.java:105)
      com.mongodb.internal.connection.RequestMessage.encode(RequestMessage.java:94)
      com.mongodb.internal.connection.CommandMessage.encode(CommandMessage.java:73)
      com.mongodb.internal.connection.InternalStreamConnection.sendAndReceiveAsyncInternal(InternalStreamConnection.java:555)
      com.mongodb.internal.connection.InternalStreamConnection.lambda$sendAndReceiveAsync$1(InternalStreamConnection.java:392)
      com.mongodb.internal.async.AsyncSupplier.finish(AsyncSupplier.java:68)
      com.mongodb.internal.async.AsyncSupplier.getAsync(AsyncSupplier.java:49)
      com.mongodb.internal.connection.InternalStreamConnection.lambda$sendAndReceiveAsync$2(InternalStreamConnection.java:395)
      com.mongodb.internal.async.AsyncSupplier.finish(AsyncSupplier.java:68)
      com.mongodb.internal.async.AsyncRunnable.lambda$thenSupply$7(AsyncRunnable.java:218)
      com.mongodb.internal.async.SingleResultCallback.complete(SingleResultCallback.java:63)
      com.mongodb.internal.async.AsyncRunnable.lambda$beginAsync$0(AsyncRunnable.java:123)
      com.mongodb.internal.async.AsyncRunnable.lambda$thenSupply$8(AsyncRunnable.java:216)
      com.mongodb.internal.async.AsyncSupplier.finish(AsyncSupplier.java:68)
      com.mongodb.internal.async.AsyncSupplier.lambda$onErrorIf$8(AsyncSupplier.java:171)
      com.mongodb.internal.async.AsyncSupplier.finish(AsyncSupplier.java:68)
      com.mongodb.internal.connection.InternalStreamConnection.sendAndReceiveAsync(InternalStreamConnection.java:398)
      com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceiveAsync(UsageTrackingInternalConnection.java:141)
      com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceiveAsync(DefaultConnectionPool.java:782)
      com.mongodb.internal.connection.CommandProtocolImpl.executeAsync(CommandProtocolImpl.java:66)
      com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.executeAsync(DefaultServer.java:230)
      com.mongodb.internal.connection.DefaultServerConnection.executeProtocolAsync(DefaultServerConnection.java:119)
      com.mongodb.internal.connection.DefaultServerConnection.commandAsync(DefaultServerConnection.java:100)
      com.mongodb.internal.connection.DefaultServerConnection.commandAsync(DefaultServerConnection.java:92)
      com.mongodb.internal.connection.DefaultServer$AsyncOperationCountTrackingConnection.commandAsync(DefaultServer.java:359)
      com.mongodb.internal.operation.AsyncOperationHelper.lambda$executeRetryableWriteAsync$12(AsyncOperationHelper.java:286)
      com.mongodb.internal.operation.AsyncOperationHelper.lambda$withAsyncSourceAndConnection$0(AsyncOperationHelper.java:121)
      com.mongodb.internal.operation.AsyncOperationHelper.lambda$withAsyncSuppliedResource$2(AsyncOperationHelper.java:138)
      com.mongodb.internal.async.function.AsyncCallbackSupplier.lambda$whenComplete$2(AsyncCallbackSupplier.java:97)
      com.mongodb.internal.operation.AsyncOperationHelper.lambda$withAsyncSuppliedResource$3(AsyncOperationHelper.java:139)
      com.mongodb.internal.connection.DefaultServer.lambda$getConnectionAsync$0(DefaultServer.java:127)
      datadog.trace.instrumentation.mongo.CallbackWrapper.onResult(CallbackWrapper.java:31)
      com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:47)
      com.mongodb.internal.connection.DefaultConnectionPool.lambda$getAsync$0(DefaultConnectionPool.java:219)
      com.mongodb.internal.connection.DefaultConnectionPool.lambda$getAsync$1(DefaultConnectionPool.java:242)
      com.mongodb.internal.connection.DefaultConnectionPool$Task.doComplete(DefaultConnectionPool.java:1433)
      com.mongodb.internal.connection.DefaultConnectionPool$Task.execute(DefaultConnectionPool.java:1419)
      com.mongodb.internal.connection.DefaultConnectionPool$AsyncWorkManager.lambda$workerRun$4(DefaultConnectionPool.java:1356)
      com.mongodb.internal.time.Timeout.lambda$run$9(Timeout.java:200)
      com.mongodb.internal.time.TimePoint.checkedCall(TimePoint.java:101)
      com.mongodb.internal.time.Timeout.call(Timeout.java:176)
      com.mongodb.internal.time.Timeout.run(Timeout.java:196)
      com.mongodb.internal.connection.DefaultConnectionPool$AsyncWorkManager.workerRun(DefaultConnectionPool.java:1354)
      com.mongodb.internal.connection.DefaultConnectionPool$AsyncWorkManager.runAndLogUncaught(DefaultConnectionPool.java:1383)
      com.mongodb.internal.connection.DefaultConnectionPool$AsyncWorkManager.lambda$initUnlessClosed$1(DefaultConnectionPool.java:1324)
      java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:545)
      java.base/java.util.concurrent.FutureTask.run(FutureTask.java:328)
      java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1090)
      java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:614)
      java.base/java.lang.Thread.run(Thread.java:1474)
      #11:
      io.netty.buffer.AdvancedLeakAwareByteBuf.order(AdvancedLeakAwareByteBuf.java:71)
      com.mongodb.internal.connection.netty.NettyByteBuf.<init>(NettyByteBuf.java:40)
      com.mongodb.internal.connection.netty.NettyStream.getBuffer(NettyStream.java:160)
      com.mongodb.internal.connection.InternalStreamConnection.getBuffer(InternalStreamConnection.java:872)
      com.mongodb.internal.connection.ByteBufferBsonOutput.getByteBufferAtIndex(ByteBufferBsonOutput.java:190)
      com.mongodb.internal.connection.ByteBufferBsonOutput.getCurrentByteBuffer(ByteBufferBsonOutput.java:176)
      com.mongodb.internal.connection.ByteBufferBsonOutput.writeInt32(ByteBufferBsonOutput.java:91)
      com.mongodb.internal.connection.RequestMessage.writeMessagePrologue(RequestMessage.java:105)
      com.mongodb.internal.connection.RequestMessage.encode(RequestMessage.java:94)
      com.mongodb.internal.connection.CommandMessage.encode(CommandMessage.java:73)
      com.mongodb.internal.connection.InternalStreamConnection.sendAndReceiveAsyncInternal(InternalStreamConnection.java:555)
      com.mongodb.internal.connection.InternalStreamConnection.lambda$sendAndReceiveAsync$1(InternalStreamConnection.java:392)
      com.mongodb.internal.async.AsyncSupplier.finish(AsyncSupplier.java:68)
      com.mongodb.internal.async.AsyncSupplier.getAsync(AsyncSupplier.java:49)
      com.mongodb.internal.connection.InternalStreamConnection.lambda$sendAndReceiveAsync$2(InternalStreamConnection.java:395)
      com.mongodb.internal.async.AsyncSupplier.finish(AsyncSupplier.java:68)
      com.mongodb.internal.async.AsyncRunnable.lambda$thenSupply$7(AsyncRunnable.java:218)
      com.mongodb.internal.async.SingleResultCallback.complete(SingleResultCallback.java:63)
      com.mongodb.internal.async.AsyncRunnable.lambda$beginAsync$0(AsyncRunnable.java:123)
      com.mongodb.internal.async.AsyncRunnable.lambda$thenSupply$8(AsyncRunnable.java:216)
      com.mongodb.internal.async.AsyncSupplier.finish(AsyncSupplier.java:68)
      com.mongodb.internal.async.AsyncSupplier.lambda$onErrorIf$8(AsyncSupplier.java:171)
      com.mongodb.internal.async.AsyncSupplier.finish(AsyncSupplier.java:68)
      com.mongodb.internal.connection.InternalStreamConnection.sendAndReceiveAsync(InternalStreamConnection.java:398)
      com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceiveAsync(UsageTrackingInternalConnection.java:141)
      com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceiveAsync(DefaultConnectionPool.java:782)
      com.mongodb.internal.connection.CommandProtocolImpl.executeAsync(CommandProtocolImpl.java:66)
      com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.executeAsync(DefaultServer.java:230)
      com.mongodb.internal.connection.DefaultServerConnection.executeProtocolAsync(DefaultServerConnection.java:119)
      com.mongodb.internal.connection.DefaultServerConnection.commandAsync(DefaultServerConnection.java:100)
      com.mongodb.internal.connection.DefaultServerConnection.commandAsync(DefaultServerConnection.java:92)
      com.mongodb.internal.connection.DefaultServer$AsyncOperationCountTrackingConnection.commandAsync(DefaultServer.java:359)
      com.mongodb.internal.operation.AsyncOperationHelper.lambda$executeRetryableWriteAsync$12(AsyncOperationHelper.java:286)
      com.mongodb.internal.operation.AsyncOperationHelper.lambda$withAsyncSourceAndConnection$0(AsyncOperationHelper.java:121)
      com.mongodb.internal.operation.AsyncOperationHelper.lambda$withAsyncSuppliedResource$2(AsyncOperationHelper.java:138)
      com.mongodb.internal.async.function.AsyncCallbackSupplier.lambda$whenComplete$2(AsyncCallbackSupplier.java:97)
      com.mongodb.internal.operation.AsyncOperationHelper.lambda$withAsyncSuppliedResource$3(AsyncOperationHelper.java:139)
      com.mongodb.internal.connection.DefaultServer.lambda$getConnectionAsync$0(DefaultServer.java:127)
      datadog.trace.instrumentation.mongo.CallbackWrapper.onResult(CallbackWrapper.java:31)
      com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:47)
      com.mongodb.internal.connection.DefaultConnectionPool.lambda$getAsync$0(DefaultConnectionPool.java:219)
      com.mongodb.internal.connection.DefaultConnectionPool.lambda$getAsync$1(DefaultConnectionPool.java:242)
      com.mongodb.internal.connection.DefaultConnectionPool$Task.doComplete(DefaultConnectionPool.java:1433)
      com.mongodb.internal.connection.DefaultConnectionPool$Task.execute(DefaultConnectionPool.java:1419)
      com.mongodb.internal.connection.DefaultConnectionPool$AsyncWorkManager.lambda$workerRun$4(DefaultConnectionPool.java:1356)
      com.mongodb.internal.time.Timeout.lambda$run$9(Timeout.java:200)
      com.mongodb.internal.time.TimePoint.checkedCall(TimePoint.java:101)
      com.mongodb.internal.time.Timeout.call(Timeout.java:176)
      com.mongodb.internal.time.Timeout.run(Timeout.java:196)
      com.mongodb.internal.connection.DefaultConnectionPool$AsyncWorkManager.workerRun(DefaultConnectionPool.java:1354)
      com.mongodb.internal.connection.DefaultConnectionPool$AsyncWorkManager.runAndLogUncaught(DefaultConnectionPool.java:1383)
      com.mongodb.internal.connection.DefaultConnectionPool$AsyncWorkManager.lambda$initUnlessClosed$1(DefaultConnectionPool.java:1324)
      java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:545)
      java.base/java.util.concurrent.FutureTask.run(FutureTask.java:328)
      java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1090)
      java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:614)
      java.base/java.lang.Thread.run(Thread.java:1474)
      Created at:
      io.netty.buffer.AdaptiveByteBufAllocator.newDirectBuffer(AdaptiveByteBufAllocator.java:67)
      io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:168)
      io.netty.buffer.AbstractByteBufAllocator.buffer(AbstractByteBufAllocator.java:104)
      com.mongodb.internal.connection.netty.NettyStream.getBuffer(NettyStream.java:160)
      com.mongodb.internal.connection.InternalStreamConnection.getBuffer(InternalStreamConnection.java:872)
      com.mongodb.internal.connection.ByteBufferBsonOutput.getByteBufferAtIndex(ByteBufferBsonOutput.java:190)
      com.mongodb.internal.connection.ByteBufferBsonOutput.getCurrentByteBuffer(ByteBufferBsonOutput.java:176)
      com.mongodb.internal.connection.ByteBufferBsonOutput.writeInt32(ByteBufferBsonOutput.java:91)
      com.mongodb.internal.connection.RequestMessage.writeMessagePrologue(RequestMessage.java:105)
      com.mongodb.internal.connection.RequestMessage.encode(RequestMessage.java:94)
      com.mongodb.internal.connection.CommandMessage.encode(CommandMessage.java:73)
      com.mongodb.internal.connection.InternalStreamConnection.sendAndReceiveAsyncInternal(InternalStreamConnection.java:555)
      com.mongodb.internal.connection.InternalStreamConnection.lambda$sendAndReceiveAsync$1(InternalStreamConnection.java:392)
      com.mongodb.internal.async.AsyncSupplier.finish(AsyncSupplier.java:68)
      com.mongodb.internal.async.AsyncSupplier.getAsync(AsyncSupplier.java:49)
      com.mongodb.internal.connection.InternalStreamConnection.lambda$sendAndReceiveAsync$2(InternalStreamConnection.java:395)
      com.mongodb.internal.async.AsyncSupplier.finish(AsyncSupplier.java:68)
      com.mongodb.internal.async.AsyncRunnable.lambda$thenSupply$7(AsyncRunnable.java:218)
      com.mongodb.internal.async.SingleResultCallback.complete(SingleResultCallback.java:63)
      com.mongodb.internal.async.AsyncRunnable.lambda$beginAsync$0(AsyncRunnable.java:123)
      com.mongodb.internal.async.AsyncRunnable.lambda$thenSupply$8(AsyncRunnable.java:216)
      com.mongodb.internal.async.AsyncSupplier.finish(AsyncSupplier.java:68)
      com.mongodb.internal.async.AsyncSupplier.lambda$onErrorIf$8(AsyncSupplier.java:171)
      com.mongodb.internal.async.AsyncSupplier.finish(AsyncSupplier.java:68)
      com.mongodb.internal.connection.InternalStreamConnection.sendAndReceiveAsync(InternalStreamConnection.java:398)
      com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceiveAsync(UsageTrackingInternalConnection.java:141)
      com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceiveAsync(DefaultConnectionPool.java:782)
      com.mongodb.internal.connection.CommandProtocolImpl.executeAsync(CommandProtocolImpl.java:66)
      com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.executeAsync(DefaultServer.java:230)
      com.mongodb.internal.connection.DefaultServerConnection.executeProtocolAsync(DefaultServerConnection.java:119)
      com.mongodb.internal.connection.DefaultServerConnection.commandAsync(DefaultServerConnection.java:100)
      com.mongodb.internal.connection.DefaultServerConnection.commandAsync(DefaultServerConnection.java:92)
      com.mongodb.internal.connection.DefaultServer$AsyncOperationCountTrackingConnection.commandAsync(DefaultServer.java:359)
      com.mongodb.internal.operation.AsyncOperationHelper.lambda$executeRetryableWriteAsync$12(AsyncOperationHelper.java:286)
      com.mongodb.internal.operation.AsyncOperationHelper.lambda$withAsyncSourceAndConnection$0(AsyncOperationHelper.java:121)
      com.mongodb.internal.operation.AsyncOperationHelper.lambda$withAsyncSuppliedResource$2(AsyncOperationHelper.java:138)
      com.mongodb.internal.async.function.AsyncCallbackSupplier.lambda$whenComplete$2(AsyncCallbackSupplier.java:97)
      com.mongodb.internal.operation.AsyncOperationHelper.lambda$withAsyncSuppliedResource$3(AsyncOperationHelper.java:139)
      com.mongodb.internal.connection.DefaultServer.lambda$getConnectionAsync$0(DefaultServer.java:127)
      datadog.trace.instrumentation.mongo.CallbackWrapper.onResult(CallbackWrapper.java:31)
      com.mongodb.internal.async.ErrorHandlingResultCallback.onResult(ErrorHandlingResultCallback.java:47)
      com.mongodb.internal.connection.DefaultConnectionPool.lambda$getAsync$0(DefaultConnectionPool.java:219)
      com.mongodb.internal.connection.DefaultConnectionPool.lambda$getAsync$1(DefaultConnectionPool.java:242)
      com.mongodb.internal.connection.DefaultConnectionPool$Task.doComplete(DefaultConnectionPool.java:1433)
      com.mongodb.internal.connection.DefaultConnectionPool$Task.execute(DefaultConnectionPool.java:1419)
      com.mongodb.internal.connection.DefaultConnectionPool$AsyncWorkManager.lambda$workerRun$4(DefaultConnectionPool.java:1356)
      com.mongodb.internal.time.Timeout.lambda$run$9(Timeout.java:200)
      com.mongodb.internal.time.TimePoint.checkedCall(TimePoint.java:101)
      com.mongodb.internal.time.Timeout.call(Timeout.java:176)
      com.mongodb.internal.time.Timeout.run(Timeout.java:196)
      com.mongodb.internal.connection.DefaultConnectionPool$AsyncWorkManager.workerRun(DefaultConnectionPool.java:1354)
      com.mongodb.internal.connection.DefaultConnectionPool$AsyncWorkManager.runAndLogUncaught(DefaultConnectionPool.java:1383)
      com.mongodb.internal.connection.DefaultConnectionPool$AsyncWorkManager.lambda$initUnlessClosed$1(DefaultConnectionPool.java:1324)
      java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:545)
      java.base/java.util.concurrent.FutureTask.run(FutureTask.java:328)
      java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1090)
      java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:614)
      java.base/java.lang.Thread.run(Thread.java:1474)
      : 337 leak records were discarded because the leak record count is targeted to 4. Use system property io.netty.leakDetection.targetRecords to increase the limit.

      Best regards,
      Norman

            Assignee:
            Unassigned
            Reporter:
            Norman Lange
            None
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

              Created:
              Updated:
              Resolved: