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

[vachudj]

Hello,
I have registered unexpected netty byteBuff leak.
It seems to be a library logic with no ability to influence it from outside of the code.
It happens randomly unfortunately not able to reproduce. Here is log from leak detection set as PARANOID level.
Maybe abybody has an idea what's wrong?

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.order(AdvancedLeakAwareByteBuf.java:71) io.netty.buffer.CompositeByteBuf.newComponent(CompositeByteBuf.java:346) io.netty.buffer.CompositeByteBuf.addComponent0(CompositeByteBuf.java:287) io.netty.buffer.CompositeByteBuf.addComponent(CompositeByteBuf.java:265) io.netty.buffer.CompositeByteBuf.addComponent(CompositeByteBuf.java:222) io.r2dbc.postgresql.PostgresqlStatement.lambda$null$12(PostgresqlStatement.java:288) reactor.core.publisher.MonoReduceSeed$ReduceSeedSubscriber.onNext(MonoReduceSeed.java:116) reactor.core.publisher.MonoSupplier$MonoSupplierSubscription.request(MonoSupplier.java:145) reactor.core.publisher.Operators$BaseFluxToMonoOperator.request(Operators.java:2067) reactor.core.publisher.Operators$MultiSubscriptionSubscriber.request(Operators.java:2331) reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.request(FluxConcatMapNoPrefetch.java:339) reactor.core.publisher.Operators$BaseFluxToMonoOperator.request(Operators.java:2067) reactor.core.publisher.MonoFlatMapMany$FlatMapManyMain.onSubscribe(MonoFlatMapMany.java:141) reactor.core.publisher.Operators$BaseFluxToMonoOperator.onSubscribe(Operators.java:2051) reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.onSubscribe(FluxConcatMapNoPrefetch.java:164) reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:201) reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:83) reactor.core.publisher.Flux.subscribe(Flux.java:8848) reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:430) reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:539) reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:122) reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:122) reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2571) reactor.core.publisher.FluxMap$MapSubscriber.request(FluxMap.java:164) reactor.core.publisher.FluxMap$MapSubscriber.request(FluxMap.java:164) reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.request(FluxOnAssembly.java:649) reactor.core.publisher.FluxFlatMap$FlatMapMain.onSubscribe(FluxFlatMap.java:373) reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onSubscribe(FluxOnAssembly.java:633) reactor.core.publisher.FluxMap$MapSubscriber.onSubscribe(FluxMap.java:92) reactor.core.publisher.FluxMap$MapSubscriber.onSubscribe(FluxMap.java:92) reactor.core.publisher.FluxJust.subscribe(FluxJust.java:68) reactor.core.publisher.FluxDefer.subscribe(FluxDefer.java:54) reactor.core.publisher.Flux.subscribe(Flux.java:8848) reactor.core.publisher.FluxUsingWhen$ResourceSubscriber.onNext(FluxUsingWhen.java:198) reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:122) reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:79) reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:79) reactor.core.publisher.FluxRetry$RetrySubscriber.onNext(FluxRetry.java:88) reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:245) reactor.core.publisher.MonoFlatMap$FlatMapInner.onNext(MonoFlatMap.java:305) io.r2dbc.pool.MonoDiscardOnCancel$MonoDiscardOnCancelSubscriber.onNext(MonoDiscardOnCancel.java:92) reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:79) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.complete(MonoIgnoreThen.java:294) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onNext(MonoIgnoreThen.java:188) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:237) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:204) reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:89) reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.onComplete(FluxHandleFuseable.java:239) reactor.core.publisher.MonoSupplier$MonoSupplierSubscription.request(MonoSupplier.java:148) reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.request(FluxHandleFuseable.java:260) reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onSubscribe(MonoIgnoreElements.java:72) reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.onSubscribe(FluxHandleFuseable.java:164) reactor.core.publisher.MonoSupplier.subscribe(MonoSupplier.java:48) reactor.core.publisher.Mono.subscribe(Mono.java:4576) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:265) reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:51) reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76) io.r2dbc.pool.MonoDiscardOnCancel.subscribe(MonoDiscardOnCancel.java:50) reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:165) reactor.pool.AbstractPool$Borrower.deliver(AbstractPool.java:472) reactor.pool.SimpleDequePool.lambda$drainLoop$8(SimpleDequePool.java:375) reactor.core.scheduler.ImmediateScheduler.schedule(ImmediateScheduler.java:52) reactor.pool.SimpleDequePool.drainLoop(SimpleDequePool.java:375) reactor.pool.SimpleDequePool.pendingOffer(SimpleDequePool.java:618) reactor.pool.SimpleDequePool.doAcquire(SimpleDequePool.java:301) reactor.pool.AbstractPool$Borrower.request(AbstractPool.java:426) reactor.core.publisher.MonoFlatMap$FlatMapMain.request(MonoFlatMap.java:194) reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:2367) reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:2241) reactor.core.publisher.MonoFlatMap$FlatMapMain.onSubscribe(MonoFlatMap.java:117) reactor.pool.SimpleDequePool$QueueBorrowerMono.subscribe(SimpleDequePool.java:736) reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76) reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53) reactor.core.publisher.FluxRetry$RetrySubscriber.resubscribe(FluxRetry.java:120) reactor.core.publisher.MonoRetry.subscribeOrReturn(MonoRetry.java:50) reactor.core.publisher.Mono.subscribe(Mono.java:4560) reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:103) reactor.core.publisher.MonoFlatMap$FlatMapMain.onError(MonoFlatMap.java:180) reactor.core.publisher.FluxMap$MapSubscriber.onError(FluxMap.java:134) reactor.core.publisher.Operators.error(Operators.java:198) reactor.core.publisher.MonoError.subscribe(MonoError.java:53) reactor.core.publisher.MonoDeferContextual.subscribe(MonoDeferContextual.java:55) reactor.core.publisher.Mono.subscribe(Mono.java:4576) reactor.core.publisher.FluxUsingWhen.subscribe(FluxUsingWhen.java:105) reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76) reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53) reactor.core.publisher.Mono.subscribe(Mono.java:4576) reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:82) reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:152) reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:299) reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:940) reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:2231) reactor.core.publisher.MonoSingle$SingleSubscriber.onComplete(MonoSingle.java:164) reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:2231) reactor.core.publisher.FluxUsingWhen$UsingWhenSubscriber.deferredComplete(FluxUsingWhen.java:397) reactor.core.publisher.FluxUsingWhen$CommitInner.onComplete(FluxUsingWhen.java:532) reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:2231) reactor.core.publisher.FluxPeek$PeekSubscriber.onComplete(FluxPeek.java:260) reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:2231) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:210) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:210) reactor.pool.SimpleDequePool.maybeRecycleAndDrain(SimpleDequePool.java:540) reactor.pool.SimpleDequePool$QueuePoolRecyclerInner.onComplete(SimpleDequePool.java:781) reactor.core.publisher.Operators.complete(Operators.java:137) reactor.core.publisher.MonoEmpty.subscribe(MonoEmpty.java:46) reactor.core.publisher.Mono.subscribe(Mono.java:4576) reactor.pool.SimpleDequePool$QueuePoolRecyclerMono.subscribe(SimpleDequePool.java:893) reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:241) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:204) reactor.core.publisher.FluxPeek$PeekSubscriber.onComplete(FluxPeek.java:260) reactor.core.publisher.Operators.complete(Operators.java:137) reactor.core.publisher.MonoEmpty.subscribe(MonoEmpty.java:46) reactor.core.publisher.Mono.subscribe(Mono.java:4576) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:265) reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:51) reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:241) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:204) reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:89) reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.onComplete(FluxHandleFuseable.java:239) reactor.core.publisher.MonoSupplier$MonoSupplierSubscription.request(MonoSupplier.java:148) reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.request(FluxHandleFuseable.java:260) reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onSubscribe(MonoIgnoreElements.java:72) reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.onSubscribe(FluxHandleFuseable.java:164) reactor.core.publisher.MonoSupplier.subscribe(MonoSupplier.java:48) reactor.core.publisher.Mono.subscribe(Mono.java:4576) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:265) reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:51) reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76) reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53) reactor.core.publisher.Mono.subscribe(Mono.java:4576) reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:103) reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onError(MonoIgnoreElements.java:84) reactor.core.publisher.FluxMap$MapSubscriber.onError(FluxMap.java:134) reactor.core.publisher.FluxFilter$FilterSubscriber.onError(FluxFilter.java:157) reactor.core.publisher.FluxFilter$FilterConditionalSubscriber.onError(FluxFilter.java:291) reactor.core.publisher.FluxMap$MapConditionalSubscriber.onError(FluxMap.java:265) reactor.core.publisher.Operators.error(Operators.java:198) reactor.core.publisher.MonoError.subscribe(MonoError.java:53) reactor.core.publisher.MonoDeferContextual.subscribe(MonoDeferContextual.java:55) reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76) reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53) reactor.core.publisher.Mono.subscribe(Mono.java:4576) reactor.core.publisher.FluxUsingWhen$UsingWhenSubscriber.onComplete(FluxUsingWhen.java:389) reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:850) reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:612) reactor.core.publisher.FluxFlatMap$FlatMapMain.innerComplete(FluxFlatMap.java:898) reactor.core.publisher.FluxFlatMap$FlatMapInner.onComplete(FluxFlatMap.java:1001) reactor.core.publisher.FluxHandle$HandleSubscriber.onComplete(FluxHandle.java:223) reactor.core.publisher.MonoFlatMapMany$FlatMapManyInner.onComplete(MonoFlatMapMany.java:261) reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.onComplete(FluxHandleFuseable.java:239) reactor.core.publisher.FluxFilterFuseable$FilterFuseableConditionalSubscriber.onComplete(FluxFilterFuseable.java:391) reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onComplete(FluxContextWrite.java:126) reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:940) reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:940) io.r2dbc.postgresql.util.FluxDiscardOnCancel$FluxDiscardOnCancelSubscriber.onComplete(FluxDiscardOnCancel.java:104) reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.onComplete(FluxDoFinally.java:128) reactor.core.publisher.FluxHandle$HandleSubscriber.onComplete(FluxHandle.java:223) reactor.core.publisher.FluxCreate$BaseSink.complete(FluxCreate.java:465) reactor.core.publisher.FluxCreate$BufferAsyncSink.drain(FluxCreate.java:871) reactor.core.publisher.FluxCreate$BufferAsyncSink.complete(FluxCreate.java:819) reactor.core.publisher.FluxCreate$SerializedFluxSink.drainLoop(FluxCreate.java:249) reactor.core.publisher.FluxCreate$SerializedFluxSink.drain(FluxCreate.java:215) reactor.core.publisher.FluxCreate$SerializedFluxSink.complete(FluxCreate.java:206) io.r2dbc.postgresql.client.ReactorNettyClient$Conversation.complete(ReactorNettyClient.java:668) io.r2dbc.postgresql.client.ReactorNettyClient$BackendMessageSubscriber.emit(ReactorNettyClient.java:934) io.r2dbc.postgresql.client.ReactorNettyClient$BackendMessageSubscriber.onNext(ReactorNettyClient.java:810) io.r2dbc.postgresql.client.ReactorNettyClient$BackendMessageSubscriber.onNext(ReactorNettyClient.java:716) reactor.core.publisher.FluxHandle$HandleSubscriber.onNext(FluxHandle.java:129) reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onNext(FluxPeekFuseable.java:854) reactor.core.publisher.FluxMap$MapConditionalSubscriber.onNext(FluxMap.java:224) reactor.core.publisher.FluxMap$MapConditionalSubscriber.onNext(FluxMap.java:224) reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:294) reactor.netty.channel.FluxReceive.onInboundNext(FluxReceive.java:403) reactor.netty.channel.ChannelOperations.onInboundNext(ChannelOperations.java:425) reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:115) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:346) io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:318) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1407) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:918) io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:799) io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:501) io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:399) io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994) 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:1583) #2: io.netty.buffer.AdvancedLeakAwareByteBuf.writeCharSequence(AdvancedLeakAwareByteBuf.java:893) io.r2dbc.postgresql.util.ByteBufUtils.encode(ByteBufUtils.java:58) io.r2dbc.postgresql.codec.StringCodec.lambda$doEncode$0(StringCodec.java:96) reactor.core.publisher.MonoSupplier$MonoSupplierSubscription.request(MonoSupplier.java:126) reactor.core.publisher.Operators$BaseFluxToMonoOperator.request(Operators.java:2067) reactor.core.publisher.Operators$MultiSubscriptionSubscriber.request(Operators.java:2331) reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.request(FluxConcatMapNoPrefetch.java:339) reactor.core.publisher.Operators$BaseFluxToMonoOperator.request(Operators.java:2067) reactor.core.publisher.MonoFlatMapMany$FlatMapManyMain.onSubscribe(MonoFlatMapMany.java:141) reactor.core.publisher.Operators$BaseFluxToMonoOperator.onSubscribe(Operators.java:2051) reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.onSubscribe(FluxConcatMapNoPrefetch.java:164) reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:201) reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:83) reactor.core.publisher.Flux.subscribe(Flux.java:8848) reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:430) reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:539) reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:122) reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:122) reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2571) reactor.core.publisher.FluxMap$MapSubscriber.request(FluxMap.java:164) reactor.core.publisher.FluxMap$MapSubscriber.request(FluxMap.java:164) reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.request(FluxOnAssembly.java:649) reactor.core.publisher.FluxFlatMap$FlatMapMain.onSubscribe(FluxFlatMap.java:373) reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onSubscribe(FluxOnAssembly.java:633) reactor.core.publisher.FluxMap$MapSubscriber.onSubscribe(FluxMap.java:92) reactor.core.publisher.FluxMap$MapSubscriber.onSubscribe(FluxMap.java:92) reactor.core.publisher.FluxJust.subscribe(FluxJust.java:68) reactor.core.publisher.FluxDefer.subscribe(FluxDefer.java:54) reactor.core.publisher.Flux.subscribe(Flux.java:8848) reactor.core.publisher.FluxUsingWhen$ResourceSubscriber.onNext(FluxUsingWhen.java:198) reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:122) reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:79) reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:79) reactor.core.publisher.FluxRetry$RetrySubscriber.onNext(FluxRetry.java:88) reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:245) reactor.core.publisher.MonoFlatMap$FlatMapInner.onNext(MonoFlatMap.java:305) io.r2dbc.pool.MonoDiscardOnCancel$MonoDiscardOnCancelSubscriber.onNext(MonoDiscardOnCancel.java:92) reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:79) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.complete(MonoIgnoreThen.java:294) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onNext(MonoIgnoreThen.java:188) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:237) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:204) reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:89) reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.onComplete(FluxHandleFuseable.java:239) reactor.core.publisher.MonoSupplier$MonoSupplierSubscription.request(MonoSupplier.java:148) reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.request(FluxHandleFuseable.java:260) reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onSubscribe(MonoIgnoreElements.java:72) reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.onSubscribe(FluxHandleFuseable.java:164) reactor.core.publisher.MonoSupplier.subscribe(MonoSupplier.java:48) reactor.core.publisher.Mono.subscribe(Mono.java:4576) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:265) reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:51) reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76) io.r2dbc.pool.MonoDiscardOnCancel.subscribe(MonoDiscardOnCancel.java:50) reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:165) reactor.pool.AbstractPool$Borrower.deliver(AbstractPool.java:472) reactor.pool.SimpleDequePool.lambda$drainLoop$8(SimpleDequePool.java:375) reactor.core.scheduler.ImmediateScheduler.schedule(ImmediateScheduler.java:52) reactor.pool.SimpleDequePool.drainLoop(SimpleDequePool.java:375) reactor.pool.SimpleDequePool.pendingOffer(SimpleDequePool.java:618) reactor.pool.SimpleDequePool.doAcquire(SimpleDequePool.java:301) reactor.pool.AbstractPool$Borrower.request(AbstractPool.java:426) reactor.core.publisher.MonoFlatMap$FlatMapMain.request(MonoFlatMap.java:194) reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:2367) reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:2241) reactor.core.publisher.MonoFlatMap$FlatMapMain.onSubscribe(MonoFlatMap.java:117) reactor.pool.SimpleDequePool$QueueBorrowerMono.subscribe(SimpleDequePool.java:736) reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76) reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53) reactor.core.publisher.FluxRetry$RetrySubscriber.resubscribe(FluxRetry.java:120) reactor.core.publisher.MonoRetry.subscribeOrReturn(MonoRetry.java:50) reactor.core.publisher.Mono.subscribe(Mono.java:4560) reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:103) reactor.core.publisher.MonoFlatMap$FlatMapMain.onError(MonoFlatMap.java:180) reactor.core.publisher.FluxMap$MapSubscriber.onError(FluxMap.java:134) reactor.core.publisher.Operators.error(Operators.java:198) reactor.core.publisher.MonoError.subscribe(MonoError.java:53) reactor.core.publisher.MonoDeferContextual.subscribe(MonoDeferContextual.java:55) reactor.core.publisher.Mono.subscribe(Mono.java:4576) reactor.core.publisher.FluxUsingWhen.subscribe(FluxUsingWhen.java:105) reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76) reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53) reactor.core.publisher.Mono.subscribe(Mono.java:4576) reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:82) reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:152) reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:299) reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:940) reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:2231) reactor.core.publisher.MonoSingle$SingleSubscriber.onComplete(MonoSingle.java:164) reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:2231) reactor.core.publisher.FluxUsingWhen$UsingWhenSubscriber.deferredComplete(FluxUsingWhen.java:397) reactor.core.publisher.FluxUsingWhen$CommitInner.onComplete(FluxUsingWhen.java:532) reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:2231) reactor.core.publisher.FluxPeek$PeekSubscriber.onComplete(FluxPeek.java:260) reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:2231) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:210) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:210) reactor.pool.SimpleDequePool.maybeRecycleAndDrain(SimpleDequePool.java:540) reactor.pool.SimpleDequePool$QueuePoolRecyclerInner.onComplete(SimpleDequePool.java:781) reactor.core.publisher.Operators.complete(Operators.java:137) reactor.core.publisher.MonoEmpty.subscribe(MonoEmpty.java:46) reactor.core.publisher.Mono.subscribe(Mono.java:4576) reactor.pool.SimpleDequePool$QueuePoolRecyclerMono.subscribe(SimpleDequePool.java:893) reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:241) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:204) reactor.core.publisher.FluxPeek$PeekSubscriber.onComplete(FluxPeek.java:260) reactor.core.publisher.Operators.complete(Operators.java:137) reactor.core.publisher.MonoEmpty.subscribe(MonoEmpty.java:46) reactor.core.publisher.Mono.subscribe(Mono.java:4576) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:265) reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:51) reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:241) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:204) reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:89) reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.onComplete(FluxHandleFuseable.java:239) reactor.core.publisher.MonoSupplier$MonoSupplierSubscription.request(MonoSupplier.java:148) reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.request(FluxHandleFuseable.java:260) reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onSubscribe(MonoIgnoreElements.java:72) reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.onSubscribe(FluxHandleFuseable.java:164) reactor.core.publisher.MonoSupplier.subscribe(MonoSupplier.java:48) reactor.core.publisher.Mono.subscribe(Mono.java:4576) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:265) reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:51) reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76) reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53) reactor.core.publisher.Mono.subscribe(Mono.java:4576) reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:103) reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onError(MonoIgnoreElements.java:84) reactor.core.publisher.FluxMap$MapSubscriber.onError(FluxMap.java:134) reactor.core.publisher.FluxFilter$FilterSubscriber.onError(FluxFilter.java:157) reactor.core.publisher.FluxFilter$FilterConditionalSubscriber.onError(FluxFilter.java:291) reactor.core.publisher.FluxMap$MapConditionalSubscriber.onError(FluxMap.java:265) reactor.core.publisher.Operators.error(Operators.java:198) reactor.core.publisher.MonoError.subscribe(MonoError.java:53) reactor.core.publisher.MonoDeferContextual.subscribe(MonoDeferContextual.java:55) reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76) reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53) reactor.core.publisher.Mono.subscribe(Mono.java:4576) reactor.core.publisher.FluxUsingWhen$UsingWhenSubscriber.onComplete(FluxUsingWhen.java:389) reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:850) reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:612) reactor.core.publisher.FluxFlatMap$FlatMapMain.innerComplete(FluxFlatMap.java:898) reactor.core.publisher.FluxFlatMap$FlatMapInner.onComplete(FluxFlatMap.java:1001) reactor.core.publisher.FluxHandle$HandleSubscriber.onComplete(FluxHandle.java:223) reactor.core.publisher.MonoFlatMapMany$FlatMapManyInner.onComplete(MonoFlatMapMany.java:261) reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.onComplete(FluxHandleFuseable.java:239) reactor.core.publisher.FluxFilterFuseable$FilterFuseableConditionalSubscriber.onComplete(FluxFilterFuseable.java:391) reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onComplete(FluxContextWrite.java:126) reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:940) reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:940) io.r2dbc.postgresql.util.FluxDiscardOnCancel$FluxDiscardOnCancelSubscriber.onComplete(FluxDiscardOnCancel.java:104) reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.onComplete(FluxDoFinally.java:128) reactor.core.publisher.FluxHandle$HandleSubscriber.onComplete(FluxHandle.java:223) reactor.core.publisher.FluxCreate$BaseSink.complete(FluxCreate.java:465) reactor.core.publisher.FluxCreate$BufferAsyncSink.drain(FluxCreate.java:871) reactor.core.publisher.FluxCreate$BufferAsyncSink.complete(FluxCreate.java:819) reactor.core.publisher.FluxCreate$SerializedFluxSink.drainLoop(FluxCreate.java:249) reactor.core.publisher.FluxCreate$SerializedFluxSink.drain(FluxCreate.java:215) reactor.core.publisher.FluxCreate$SerializedFluxSink.complete(FluxCreate.java:206) io.r2dbc.postgresql.client.ReactorNettyClient$Conversation.complete(ReactorNettyClient.java:668) io.r2dbc.postgresql.client.ReactorNettyClient$BackendMessageSubscriber.emit(ReactorNettyClient.java:934) io.r2dbc.postgresql.client.ReactorNettyClient$BackendMessageSubscriber.onNext(ReactorNettyClient.java:810) io.r2dbc.postgresql.client.ReactorNettyClient$BackendMessageSubscriber.onNext(ReactorNettyClient.java:716) reactor.core.publisher.FluxHandle$HandleSubscriber.onNext(FluxHandle.java:129) reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onNext(FluxPeekFuseable.java:854) reactor.core.publisher.FluxMap$MapConditionalSubscriber.onNext(FluxMap.java:224) reactor.core.publisher.FluxMap$MapConditionalSubscriber.onNext(FluxMap.java:224) reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:294) reactor.netty.channel.FluxReceive.onInboundNext(FluxReceive.java:403) reactor.netty.channel.ChannelOperations.onInboundNext(ChannelOperations.java:425) reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:115) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:346) io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:318) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1407) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:918) io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:799) io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:501) io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:399) io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994) 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:1583) Created at: io.netty.buffer.PooledByteBufAllocator.newDirectBuffer(PooledByteBufAllocator.java:410) io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:188) io.netty.buffer.AbstractByteBufAllocator.directBuffer(AbstractByteBufAllocator.java:174) io.netty.buffer.AbstractByteBufAllocator.buffer(AbstractByteBufAllocator.java:108) io.r2dbc.postgresql.util.ByteBufUtils.encode(ByteBufUtils.java:57) io.r2dbc.postgresql.codec.StringCodec.lambda$doEncode$0(StringCodec.java:96) reactor.core.publisher.MonoSupplier$MonoSupplierSubscription.request(MonoSupplier.java:126) reactor.core.publisher.Operators$BaseFluxToMonoOperator.request(Operators.java:2067) reactor.core.publisher.Operators$MultiSubscriptionSubscriber.request(Operators.java:2331) reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.request(FluxConcatMapNoPrefetch.java:339) reactor.core.publisher.Operators$BaseFluxToMonoOperator.request(Operators.java:2067) reactor.core.publisher.MonoFlatMapMany$FlatMapManyMain.onSubscribe(MonoFlatMapMany.java:141) reactor.core.publisher.Operators$BaseFluxToMonoOperator.onSubscribe(Operators.java:2051) reactor.core.publisher.FluxConcatMapNoPrefetch$FluxConcatMapNoPrefetchSubscriber.onSubscribe(FluxConcatMapNoPrefetch.java:164) reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:201) reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:83) reactor.core.publisher.Flux.subscribe(Flux.java:8848) reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:430) reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onNext(FluxOnAssembly.java:539) reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:122) reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:122) reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2571) reactor.core.publisher.FluxMap$MapSubscriber.request(FluxMap.java:164) reactor.core.publisher.FluxMap$MapSubscriber.request(FluxMap.java:164) reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.request(FluxOnAssembly.java:649) reactor.core.publisher.FluxFlatMap$FlatMapMain.onSubscribe(FluxFlatMap.java:373) reactor.core.publisher.FluxOnAssembly$OnAssemblySubscriber.onSubscribe(FluxOnAssembly.java:633) reactor.core.publisher.FluxMap$MapSubscriber.onSubscribe(FluxMap.java:92) reactor.core.publisher.FluxMap$MapSubscriber.onSubscribe(FluxMap.java:92) reactor.core.publisher.FluxJust.subscribe(FluxJust.java:68) reactor.core.publisher.FluxDefer.subscribe(FluxDefer.java:54) reactor.core.publisher.Flux.subscribe(Flux.java:8848) reactor.core.publisher.FluxUsingWhen$ResourceSubscriber.onNext(FluxUsingWhen.java:198) reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:122) reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:79) reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:79) reactor.core.publisher.FluxRetry$RetrySubscriber.onNext(FluxRetry.java:88) reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:245) reactor.core.publisher.MonoFlatMap$FlatMapInner.onNext(MonoFlatMap.java:305) io.r2dbc.pool.MonoDiscardOnCancel$MonoDiscardOnCancelSubscriber.onNext(MonoDiscardOnCancel.java:92) reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:79) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.complete(MonoIgnoreThen.java:294) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onNext(MonoIgnoreThen.java:188) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:237) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:204) reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:89) reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.onComplete(FluxHandleFuseable.java:239) reactor.core.publisher.MonoSupplier$MonoSupplierSubscription.request(MonoSupplier.java:148) reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.request(FluxHandleFuseable.java:260) reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onSubscribe(MonoIgnoreElements.java:72) reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.onSubscribe(FluxHandleFuseable.java:164) reactor.core.publisher.MonoSupplier.subscribe(MonoSupplier.java:48) reactor.core.publisher.Mono.subscribe(Mono.java:4576) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:265) reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:51) reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76) io.r2dbc.pool.MonoDiscardOnCancel.subscribe(MonoDiscardOnCancel.java:50) reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:165) reactor.pool.AbstractPool$Borrower.deliver(AbstractPool.java:472) reactor.pool.SimpleDequePool.lambda$drainLoop$8(SimpleDequePool.java:375) reactor.core.scheduler.ImmediateScheduler.schedule(ImmediateScheduler.java:52) reactor.pool.SimpleDequePool.drainLoop(SimpleDequePool.java:375) reactor.pool.SimpleDequePool.pendingOffer(SimpleDequePool.java:618) reactor.pool.SimpleDequePool.doAcquire(SimpleDequePool.java:301) reactor.pool.AbstractPool$Borrower.request(AbstractPool.java:426) reactor.core.publisher.MonoFlatMap$FlatMapMain.request(MonoFlatMap.java:194) reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:2367) reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:2241) reactor.core.publisher.MonoFlatMap$FlatMapMain.onSubscribe(MonoFlatMap.java:117) reactor.pool.SimpleDequePool$QueueBorrowerMono.subscribe(SimpleDequePool.java:736) reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76) reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53) reactor.core.publisher.FluxRetry$RetrySubscriber.resubscribe(FluxRetry.java:120) reactor.core.publisher.MonoRetry.subscribeOrReturn(MonoRetry.java:50) reactor.core.publisher.Mono.subscribe(Mono.java:4560) reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:103) reactor.core.publisher.MonoFlatMap$FlatMapMain.onError(MonoFlatMap.java:180) reactor.core.publisher.FluxMap$MapSubscriber.onError(FluxMap.java:134) reactor.core.publisher.Operators.error(Operators.java:198) reactor.core.publisher.MonoError.subscribe(MonoError.java:53) reactor.core.publisher.MonoDeferContextual.subscribe(MonoDeferContextual.java:55) reactor.core.publisher.Mono.subscribe(Mono.java:4576) reactor.core.publisher.FluxUsingWhen.subscribe(FluxUsingWhen.java:105) reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76) reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53) reactor.core.publisher.Mono.subscribe(Mono.java:4576) reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:82) reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:152) reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:299) reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:940) reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:2231) reactor.core.publisher.MonoSingle$SingleSubscriber.onComplete(MonoSingle.java:164) reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:2231) reactor.core.publisher.FluxUsingWhen$UsingWhenSubscriber.deferredComplete(FluxUsingWhen.java:397) reactor.core.publisher.FluxUsingWhen$CommitInner.onComplete(FluxUsingWhen.java:532) reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:2231) reactor.core.publisher.FluxPeek$PeekSubscriber.onComplete(FluxPeek.java:260) reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:2231) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:210) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:210) reactor.pool.SimpleDequePool.maybeRecycleAndDrain(SimpleDequePool.java:540) reactor.pool.SimpleDequePool$QueuePoolRecyclerInner.onComplete(SimpleDequePool.java:781) reactor.core.publisher.Operators.complete(Operators.java:137) reactor.core.publisher.MonoEmpty.subscribe(MonoEmpty.java:46) reactor.core.publisher.Mono.subscribe(Mono.java:4576) reactor.pool.SimpleDequePool$QueuePoolRecyclerMono.subscribe(SimpleDequePool.java:893) reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:241) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:204) reactor.core.publisher.FluxPeek$PeekSubscriber.onComplete(FluxPeek.java:260) reactor.core.publisher.Operators.complete(Operators.java:137) reactor.core.publisher.MonoEmpty.subscribe(MonoEmpty.java:46) reactor.core.publisher.Mono.subscribe(Mono.java:4576) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:265) reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:51) reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:241) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.onComplete(MonoIgnoreThen.java:204) reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:89) reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.onComplete(FluxHandleFuseable.java:239) reactor.core.publisher.MonoSupplier$MonoSupplierSubscription.request(MonoSupplier.java:148) reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.request(FluxHandleFuseable.java:260) reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onSubscribe(MonoIgnoreElements.java:72) reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.onSubscribe(FluxHandleFuseable.java:164) reactor.core.publisher.MonoSupplier.subscribe(MonoSupplier.java:48) reactor.core.publisher.Mono.subscribe(Mono.java:4576) reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.subscribeNext(MonoIgnoreThen.java:265) reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:51) reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76) reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53) reactor.core.publisher.Mono.subscribe(Mono.java:4576) reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:103) reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onError(MonoIgnoreElements.java:84) reactor.core.publisher.FluxMap$MapSubscriber.onError(FluxMap.java:134) reactor.core.publisher.FluxFilter$FilterSubscriber.onError(FluxFilter.java:157) reactor.core.publisher.FluxFilter$FilterConditionalSubscriber.onError(FluxFilter.java:291) reactor.core.publisher.FluxMap$MapConditionalSubscriber.onError(FluxMap.java:265) reactor.core.publisher.Operators.error(Operators.java:198) reactor.core.publisher.MonoError.subscribe(MonoError.java:53) reactor.core.publisher.MonoDeferContextual.subscribe(MonoDeferContextual.java:55) reactor.core.publisher.InternalMonoOperator.subscribe(InternalMonoOperator.java:76) reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:53) reactor.core.publisher.Mono.subscribe(Mono.java:4576) reactor.core.publisher.FluxUsingWhen$UsingWhenSubscriber.onComplete(FluxUsingWhen.java:389) reactor.core.publisher.FluxFlatMap$FlatMapMain.checkTerminated(FluxFlatMap.java:850) reactor.core.publisher.FluxFlatMap$FlatMapMain.drainLoop(FluxFlatMap.java:612) reactor.core.publisher.FluxFlatMap$FlatMapMain.innerComplete(FluxFlatMap.java:898) reactor.core.publisher.FluxFlatMap$FlatMapInner.onComplete(FluxFlatMap.java:1001) reactor.core.publisher.FluxHandle$HandleSubscriber.onComplete(FluxHandle.java:223) reactor.core.publisher.MonoFlatMapMany$FlatMapManyInner.onComplete(MonoFlatMapMany.java:261) reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.onComplete(FluxHandleFuseable.java:239) reactor.core.publisher.FluxFilterFuseable$FilterFuseableConditionalSubscriber.onComplete(FluxFilterFuseable.java:391) reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onComplete(FluxContextWrite.java:126) reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:940) reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:940) io.r2dbc.postgresql.util.FluxDiscardOnCancel$FluxDiscardOnCancelSubscriber.onComplete(FluxDiscardOnCancel.java:104) reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.onComplete(FluxDoFinally.java:128) reactor.core.publisher.FluxHandle$HandleSubscriber.onComplete(FluxHandle.java:223) reactor.core.publisher.FluxCreate$BaseSink.complete(FluxCreate.java:465) reactor.core.publisher.FluxCreate$BufferAsyncSink.drain(FluxCreate.java:871) reactor.core.publisher.FluxCreate$BufferAsyncSink.complete(FluxCreate.java:819) reactor.core.publisher.FluxCreate$SerializedFluxSink.drainLoop(FluxCreate.java:249) reactor.core.publisher.FluxCreate$SerializedFluxSink.drain(FluxCreate.java:215) reactor.core.publisher.FluxCreate$SerializedFluxSink.complete(FluxCreate.java:206) io.r2dbc.postgresql.client.ReactorNettyClient$Conversation.complete(ReactorNettyClient.java:668) io.r2dbc.postgresql.client.ReactorNettyClient$BackendMessageSubscriber.emit(ReactorNettyClient.java:934) io.r2dbc.postgresql.client.ReactorNettyClient$BackendMessageSubscriber.onNext(ReactorNettyClient.java:810) io.r2dbc.postgresql.client.ReactorNettyClient$BackendMessageSubscriber.onNext(ReactorNettyClient.java:716) reactor.core.publisher.FluxHandle$HandleSubscriber.onNext(FluxHandle.java:129) reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onNext(FluxPeekFuseable.java:854) reactor.core.publisher.FluxMap$MapConditionalSubscriber.onNext(FluxMap.java:224) reactor.core.publisher.FluxMap$MapConditionalSubscriber.onNext(FluxMap.java:224) reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:294) reactor.netty.channel.FluxReceive.onInboundNext(FluxReceive.java:403) reactor.netty.channel.ChannelOperations.onInboundNext(ChannelOperations.java:425) reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:115) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:346) io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:318) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412) io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1407) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440) io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420) io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:918) io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:799) io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:501) io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:399) io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:994) 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:1583)

[sivaschuck]

I am having a similar issue as well:

2025-08-11T16:21:22.021+01:00 ERROR 72172 --- [] [actor-tcp-nio-6] io.netty.util.ResourceLeakDetector       : LEAK: DataRow.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.r2dbc.postgresql.message.backend.DataRow.<init>(DataRow.java:37)
	io.r2dbc.postgresql.message.backend.DataRow.decode(DataRow.java:141)
	io.r2dbc.postgresql.message.backend.BackendMessageDecoder.decodeBody(BackendMessageDecoder.java:65)
	io.r2dbc.postgresql.message.backend.BackendMessageDecoder.decode(BackendMessageDecoder.java:39)
	reactor.core.publisher.FluxMap$MapConditionalSubscriber.onNext(FluxMap.java:208)
	reactor.core.publisher.FluxMap$MapConditionalSubscriber.onNext(FluxMap.java:224)
	reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:292)
	reactor.netty.channel.FluxReceive.onInboundNext(FluxReceive.java:401)
	reactor.netty.channel.ChannelOperations.onInboundNext(ChannelOperations.java:435)
	reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:115)
	io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
	io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
	io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
	io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:346)
	io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:333)
	io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:455)
	io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:290)
	io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:444)
	io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
	io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:412)
	io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1357)
	io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:440)
	io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:420)
	io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:868)
	io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:166)
	io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:796)
	io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:732)
	io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:658)
	io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:562)
	io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:998)
	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:1583)

All my code is doing is mapping io.r2dbc.spi.Rows from the database and converting it to our own Row model. It's not holding on to io.r2dbc.spi.Row afterwards, so I shouldn't be calling .release() myself here and I can't anyway:

...
...
    val records = bindSpec
        .map { row: io.r2dbc.spi.Row, _ ->
            val id = toRowId(row)
            val features = featuresMap.map { it ->
                if (row[it.key] != null) {
                    toFeature(controlFqn, it.key, row, featuresMap)
                } else {
                    Feature(it.value.id, it.value.fqn, it.value.name, null)
                }
            }
            Row(id, features, 0)
        }
        .flow()
        .catch { e -> throw e }
  return records
}