18600454482 opened a new issue, #10393:
URL: https://github.com/apache/skywalking/issues/10393

   ### Search before asking
   
   - [X] I had searched in the 
[issues](https://github.com/apache/skywalking/issues?q=is%3Aissue) and found no 
similar issues.
   
   
   ### Apache SkyWalking Component
   
   OAP server (apache/skywalking)
   
   ### What happened
   
   Which version of SkyWalking, OS and JRE?
   SkyWalking: 8.3.0
   Java version: 1.8
   Spring Cloud Gateway: 2.2.1.RELEASE
   
   java.lang.RuntimeException: Can not do async finish for the span repeatedly.
        at 
org.apache.skywalking.apm.agent.core.context.trace.AbstractTracingSpan.asyncFinish(AbstractTracingSpan.java:325)
 ~[skywalking-agent.jar:8.3.0]
        at 
org.apache.skywalking.apm.plugin.spring.webflux.v5.webclient.WebFluxWebClientInterceptor.lambda$afterMethod$1(WebFluxWebClientInterceptor.java:96)
 ~[?:?]
        at 
reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.runFinally(FluxDoFinally.java:156)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.onComplete(FluxDoFinally.java:139)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:292)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:292)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.FluxMap$MapConditionalSubscriber.onComplete(FluxMap.java:262)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:931)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:931)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.MonoNext$NextSubscriber.onComplete(MonoNext.java:96) 
~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:77) 
~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2148)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.MonoFlatMapMany$FlatMapManyMain.onSubscribeInner(MonoFlatMapMany.java:143)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.MonoFlatMapMany$FlatMapManyMain.onNext(MonoFlatMapMany.java:182)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.FluxRetryPredicate$RetryPredicateSubscriber.onNext(FluxRetryPredicate.java:82)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.MonoCreate$DefaultMonoSink.success(MonoCreate.java:156) 
~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.netty.http.client.HttpClientConnect$HttpObserver.onStateChange(HttpClientConnect.java:397)
 ~[reactor-netty-0.9.1.RELEASE.jar!/:0.9.1.RELEASE]
        at 
reactor.netty.ReactorNetty$CompositeConnectionObserver.onStateChange(ReactorNetty.java:473)
 ~[reactor-netty-0.9.1.RELEASE.jar!/:0.9.1.RELEASE]
        at 
reactor.netty.resources.PooledConnectionProvider$DisposableAcquire.onStateChange(PooledConnectionProvider.java:526)
 ~[reactor-netty-0.9.1.RELEASE.jar!/:0.9.1.RELEASE]
        at 
reactor.netty.resources.PooledConnectionProvider$PooledConnection.onStateChange(PooledConnectionProvider.java:435)
 ~[reactor-netty-0.9.1.RELEASE.jar!/:0.9.1.RELEASE]
        at 
reactor.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:522)
 ~[reactor-netty-0.9.1.RELEASE.jar!/:0.9.1.RELEASE]
        at 
reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:93)
 ~[reactor-netty-0.9.1.RELEASE.jar!/:0.9.1.RELEASE]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
 ~[netty-codec-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:438)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:326)
 ~[netty-codec-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:313)
 ~[netty-codec-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:427)
 ~[netty-codec-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:281)
 ~[netty-codec-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:253)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1422)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:931)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:792)
 ~[netty-transport-native-epoll-4.1.43.Final-linux-x86_64.jar!/:4.1.43.Final]
        at 
io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:502) 
~[netty-transport-native-epoll-4.1.43.Final-linux-x86_64.jar!/:4.1.43.Final]
        at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:407) 
~[netty-transport-native-epoll-4.1.43.Final-linux-x86_64.jar!/:4.1.43.Final]
        at 
io.netty.util.concurrent.SingleThreadEventExecutor$6.run(SingleThreadEventExecutor.java:1050)
 ~[netty-common-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) 
~[netty-common-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
 ~[netty-common-4.1.43.Final.jar!/:4.1.43.Final]
        at java.lang.Thread.run(Thread.java:748) [?:1.8.0_212]
   
   ### What you expected to happen
   
   java.lang.RuntimeException: Can not do async finish for the span repeatedly.
        at 
org.apache.skywalking.apm.agent.core.context.trace.AbstractTracingSpan.asyncFinish(AbstractTracingSpan.java:325)
 ~[skywalking-agent.jar:8.3.0]
        at 
org.apache.skywalking.apm.plugin.spring.webflux.v5.webclient.WebFluxWebClientInterceptor.lambda$afterMethod$1(WebFluxWebClientInterceptor.java:96)
 ~[?:?]
        at 
reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.runFinally(FluxDoFinally.java:156)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.onComplete(FluxDoFinally.java:139)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:292)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:292)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.FluxMap$MapConditionalSubscriber.onComplete(FluxMap.java:262)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:931)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:931)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.MonoNext$NextSubscriber.onComplete(MonoNext.java:96) 
~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:77) 
~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2148)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.MonoFlatMapMany$FlatMapManyMain.onSubscribeInner(MonoFlatMapMany.java:143)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.MonoFlatMapMany$FlatMapManyMain.onNext(MonoFlatMapMany.java:182)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.FluxRetryPredicate$RetryPredicateSubscriber.onNext(FluxRetryPredicate.java:82)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.MonoCreate$DefaultMonoSink.success(MonoCreate.java:156) 
~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.netty.http.client.HttpClientConnect$HttpObserver.onStateChange(HttpClientConnect.java:397)
 ~[reactor-netty-0.9.1.RELEASE.jar!/:0.9.1.RELEASE]
        at 
reactor.netty.ReactorNetty$CompositeConnectionObserver.onStateChange(ReactorNetty.java:473)
 ~[reactor-netty-0.9.1.RELEASE.jar!/:0.9.1.RELEASE]
        at 
reactor.netty.resources.PooledConnectionProvider$DisposableAcquire.onStateChange(PooledConnectionProvider.java:526)
 ~[reactor-netty-0.9.1.RELEASE.jar!/:0.9.1.RELEASE]
        at 
reactor.netty.resources.PooledConnectionProvider$PooledConnection.onStateChange(PooledConnectionProvider.java:435)
 ~[reactor-netty-0.9.1.RELEASE.jar!/:0.9.1.RELEASE]
        at 
reactor.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:522)
 ~[reactor-netty-0.9.1.RELEASE.jar!/:0.9.1.RELEASE]
        at 
reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:93)
 ~[reactor-netty-0.9.1.RELEASE.jar!/:0.9.1.RELEASE]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
 ~[netty-codec-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:438)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:326)
 ~[netty-codec-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:313)
 ~[netty-codec-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:427)
 ~[netty-codec-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:281)
 ~[netty-codec-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:253)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1422)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:931)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:792)
 ~[netty-transport-native-epoll-4.1.43.Final-linux-x86_64.jar!/:4.1.43.Final]
        at 
io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:502) 
~[netty-transport-native-epoll-4.1.43.Final-linux-x86_64.jar!/:4.1.43.Final]
        at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:407) 
~[netty-transport-native-epoll-4.1.43.Final-linux-x86_64.jar!/:4.1.43.Final]
        at 
io.netty.util.concurrent.SingleThreadEventExecutor$6.run(SingleThreadEventExecutor.java:1050)
 ~[netty-common-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) 
~[netty-common-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
 ~[netty-common-4.1.43.Final.jar!/:4.1.43.Final]
        at java.lang.Thread.run(Thread.java:748) [?:1.8.0_212]
   
   ### How to reproduce
   
   java.lang.RuntimeException: Can not do async finish for the span repeatedly.
        at 
org.apache.skywalking.apm.agent.core.context.trace.AbstractTracingSpan.asyncFinish(AbstractTracingSpan.java:325)
 ~[skywalking-agent.jar:8.3.0]
        at 
org.apache.skywalking.apm.plugin.spring.webflux.v5.webclient.WebFluxWebClientInterceptor.lambda$afterMethod$1(WebFluxWebClientInterceptor.java:96)
 ~[?:?]
        at 
reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.runFinally(FluxDoFinally.java:156)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.onComplete(FluxDoFinally.java:139)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:292)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.onComplete(MonoPeekTerminal.java:292)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.FluxMap$MapConditionalSubscriber.onComplete(FluxMap.java:262)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:931)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onComplete(FluxPeekFuseable.java:931)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.MonoNext$NextSubscriber.onComplete(MonoNext.java:96) 
~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:77) 
~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2148)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.MonoFlatMapMany$FlatMapManyMain.onSubscribeInner(MonoFlatMapMany.java:143)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.MonoFlatMapMany$FlatMapManyMain.onNext(MonoFlatMapMany.java:182)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.FluxRetryPredicate$RetryPredicateSubscriber.onNext(FluxRetryPredicate.java:82)
 ~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.core.publisher.MonoCreate$DefaultMonoSink.success(MonoCreate.java:156) 
~[reactor-core-3.3.0.RELEASE.jar!/:3.3.0.RELEASE]
        at 
reactor.netty.http.client.HttpClientConnect$HttpObserver.onStateChange(HttpClientConnect.java:397)
 ~[reactor-netty-0.9.1.RELEASE.jar!/:0.9.1.RELEASE]
        at 
reactor.netty.ReactorNetty$CompositeConnectionObserver.onStateChange(ReactorNetty.java:473)
 ~[reactor-netty-0.9.1.RELEASE.jar!/:0.9.1.RELEASE]
        at 
reactor.netty.resources.PooledConnectionProvider$DisposableAcquire.onStateChange(PooledConnectionProvider.java:526)
 ~[reactor-netty-0.9.1.RELEASE.jar!/:0.9.1.RELEASE]
        at 
reactor.netty.resources.PooledConnectionProvider$PooledConnection.onStateChange(PooledConnectionProvider.java:435)
 ~[reactor-netty-0.9.1.RELEASE.jar!/:0.9.1.RELEASE]
        at 
reactor.netty.http.client.HttpClientOperations.onInboundNext(HttpClientOperations.java:522)
 ~[reactor-netty-0.9.1.RELEASE.jar!/:0.9.1.RELEASE]
        at 
reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:93)
 ~[reactor-netty-0.9.1.RELEASE.jar!/:0.9.1.RELEASE]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
 ~[netty-codec-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:438)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:326)
 ~[netty-codec-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:313)
 ~[netty-codec-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:427)
 ~[netty-codec-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:281)
 ~[netty-codec-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:253)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1422)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:931)
 ~[netty-transport-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:792)
 ~[netty-transport-native-epoll-4.1.43.Final-linux-x86_64.jar!/:4.1.43.Final]
        at 
io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:502) 
~[netty-transport-native-epoll-4.1.43.Final-linux-x86_64.jar!/:4.1.43.Final]
        at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:407) 
~[netty-transport-native-epoll-4.1.43.Final-linux-x86_64.jar!/:4.1.43.Final]
        at 
io.netty.util.concurrent.SingleThreadEventExecutor$6.run(SingleThreadEventExecutor.java:1050)
 ~[netty-common-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) 
~[netty-common-4.1.43.Final.jar!/:4.1.43.Final]
        at 
io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
 ~[netty-common-4.1.43.Final.jar!/:4.1.43.Final]
        at java.lang.Thread.run(Thread.java:748) [?:1.8.0_212]
   
   ### Anything else
   
   _No response_
   
   ### Are you willing to submit PR?
   
   - [X] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [X] I agree to follow this project's [Code of 
Conduct](https://www.apache.org/foundation/policies/conduct)
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: 
notifications-unsubscr...@skywalking.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to