You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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?
reacted with thumbs up emoji reacted with thumbs down emoji reacted with laugh emoji reacted with hooray emoji reacted with confused emoji reacted with heart emoji reacted with rocket emoji reacted with eyes emoji
-
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)Beta Was this translation helpful? Give feedback.
All reactions