thanq opened a new issue #5144:
URL: https://github.com/apache/skywalking/issues/5144
Please answer these questions before submitting your issue.
- Why do you submit this issue?
- [ ✔️] Bug
___
### Bug
- Which version of SkyWalking, OS and JRE?
SkyWalking:8.0.1
OS: MAC/Linux
JRE: OpenJDK 1.8.0_242/1.8.0_252
- What happen?
test/plugin/scenarios/webflux-scenario demo project has problem In
concurrent scenario
when I use 1 or 2 concurrent, has no problem , but when I use 5 concurrent
with JMeter, projectB of webflux-scenario has print error log like this , I
think that means the same span closed multiple times, please check it, Thanks
```
2020-07-21 19:30:32.391 ERROR 33410 --- [ctor-http-nio-1]
reactor.core.publisher.Operators : Operator called default
onErrorDropped
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:314)
~[skywalking-agent.jar:8.0.1]
at
org.apache.skywalking.apm.plugin.spring.webflux.v5.DispatcherHandlerHandleMethodInterceptor.lambda$afterMethod$0(DispatcherHandlerHandleMethodInterceptor.java:96)
~[na:na]
at
reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.runFinally(FluxDoFinally.java:156)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.onError(FluxDoFinally.java:132)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapMain.onError(MonoFlatMap.java:165)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapMain.secondError(MonoFlatMap.java:185)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapInner.onError(MonoFlatMap.java:251)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MonoSubscriber.onError(Operators.java:1521)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoIgnoreThen$ThenIgnoreInner.onError(MonoIgnoreThen.java:235)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapMain.onError(MonoFlatMap.java:165)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onError(Operators.java:1718)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.Operators.error(Operators.java:181)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoError.subscribe(MonoError.java:52)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.Mono.subscribe(Mono.java:3608)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:75)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapMain.onComplete(MonoFlatMap.java:174)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoNext$NextSubscriber.onComplete(MonoNext.java:96)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.drain(FluxConcatMap.java:360)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.onSubscribe(FluxConcatMap.java:212)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxConcatMap.subscribe(FluxConcatMap.java:121)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoNext.subscribe(MonoNext.java:40)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoSwitchIfEmpty.subscribe(MonoSwitchIfEmpty.java:44)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.Mono.subscribe(Mono.java:3608)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:172)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:150)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:76)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.innerNext(FluxConcatMap.java:275)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxConcatMap$ConcatMapInner.onNext(FluxConcatMap.java:849)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2041)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.request(FluxMapFuseable.java:162)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:1849)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:1723)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onSubscribe(FluxMapFuseable.java:90)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoMapFuseable.subscribe(MonoMapFuseable.java:59)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.Mono.subscribe(Mono.java:3608)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.drain(FluxConcatMap.java:442)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.onSubscribe(FluxConcatMap.java:212)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxConcatMap.subscribe(FluxConcatMap.java:121)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoNext.subscribe(MonoNext.java:40)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoSwitchIfEmpty.subscribe(MonoSwitchIfEmpty.java:44)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoDoFinallyFuseable.subscribe(MonoDoFinallyFuseable.java:48)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoPeekTerminal.subscribe(MonoPeekTerminal.java:61)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.Mono.subscribe(Mono.java:3608)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:172)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoPeekFuseable.subscribe(MonoPeekFuseable.java:70)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoPeekTerminal.subscribe(MonoPeekTerminal.java:61)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.netty.http.server.HttpServerHandle.onStateChange(HttpServerHandle.java:64)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
reactor.netty.tcp.TcpServerBind$ChildObserver.onStateChange(TcpServerBind.java:226)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
reactor.netty.http.server.HttpServerOperations.onInboundNext(HttpServerOperations.java:434)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:141)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
reactor.netty.http.server.HttpTrafficHandler.channelRead(HttpTrafficHandler.java:159)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:438)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
~[netty-codec-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297)
~[netty-codec-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:253)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:648)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:583)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:500)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:462)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:897)
~[netty-common-4.1.31.Final.jar:4.1.31.Final]
at java.base/java.lang.Thread.run(Thread.java:834) ~[na:na]
2020-07-21 19:30:32.400 ERROR 33410 --- [ctor-http-nio-1]
reactor.netty.http.server.HttpServer : [id: 0x1cecdc7d, L:/127.0.0.1:18080
- R:/127.0.0.1:54636]
reactor.core.Exceptions$BubblingException: java.lang.RuntimeException: Can
not do async finish for the span repeatedly.
at reactor.core.Exceptions.bubble(Exceptions.java:154)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.Operators.onErrorDropped(Operators.java:512)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.runFinally(FluxDoFinally.java:159)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.onError(FluxDoFinally.java:132)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapMain.onError(MonoFlatMap.java:165)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapMain.secondError(MonoFlatMap.java:185)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapInner.onError(MonoFlatMap.java:251)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MonoSubscriber.onError(Operators.java:1521)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoIgnoreThen$ThenIgnoreInner.onError(MonoIgnoreThen.java:235)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapMain.onError(MonoFlatMap.java:165)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onError(Operators.java:1718)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.Operators.error(Operators.java:181)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoError.subscribe(MonoError.java:52)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.Mono.subscribe(Mono.java:3608)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onComplete(FluxSwitchIfEmpty.java:75)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapMain.onComplete(MonoFlatMap.java:174)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoNext$NextSubscriber.onComplete(MonoNext.java:96)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.drain(FluxConcatMap.java:360)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.onSubscribe(FluxConcatMap.java:212)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxConcatMap.subscribe(FluxConcatMap.java:121)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoNext.subscribe(MonoNext.java:40)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoSwitchIfEmpty.subscribe(MonoSwitchIfEmpty.java:44)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.Mono.subscribe(Mono.java:3608)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:172)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:150)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:76)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.innerNext(FluxConcatMap.java:275)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxConcatMap$ConcatMapInner.onNext(FluxConcatMap.java:849)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$ScalarSubscription.request(Operators.java:2041)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.request(FluxMapFuseable.java:162)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:1849)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:1723)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onSubscribe(FluxMapFuseable.java:90)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoJust.subscribe(MonoJust.java:54)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoMapFuseable.subscribe(MonoMapFuseable.java:59)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.Mono.subscribe(Mono.java:3608)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.drain(FluxConcatMap.java:442)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxConcatMap$ConcatMapImmediate.onSubscribe(FluxConcatMap.java:212)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:139)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.FluxIterable.subscribe(FluxIterable.java:63)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxConcatMap.subscribe(FluxConcatMap.java:121)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoNext.subscribe(MonoNext.java:40)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoSwitchIfEmpty.subscribe(MonoSwitchIfEmpty.java:44)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoDoFinallyFuseable.subscribe(MonoDoFinallyFuseable.java:48)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoDefer.subscribe(MonoDefer.java:52)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoPeekTerminal.subscribe(MonoPeekTerminal.java:61)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.Mono.subscribe(Mono.java:3608)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoIgnoreThen$ThenIgnoreMain.drain(MonoIgnoreThen.java:172)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoIgnoreThen.subscribe(MonoIgnoreThen.java:56)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoPeekFuseable.subscribe(MonoPeekFuseable.java:70)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoPeekTerminal.subscribe(MonoPeekTerminal.java:61)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.netty.http.server.HttpServerHandle.onStateChange(HttpServerHandle.java:64)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
reactor.netty.tcp.TcpServerBind$ChildObserver.onStateChange(TcpServerBind.java:226)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
reactor.netty.http.server.HttpServerOperations.onInboundNext(HttpServerOperations.java:434)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:141)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
reactor.netty.http.server.HttpTrafficHandler.channelRead(HttpTrafficHandler.java:159)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:438)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
~[netty-codec-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297)
~[netty-codec-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:253)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:648)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:583)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:500)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:462)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:897)
~[netty-common-4.1.31.Final.jar:4.1.31.Final]
at java.base/java.lang.Thread.run(Thread.java:834) ~[na:na]
Caused by: 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:314)
~[skywalking-agent.jar:8.0.1]
at
org.apache.skywalking.apm.plugin.spring.webflux.v5.DispatcherHandlerHandleMethodInterceptor.lambda$afterMethod$0(DispatcherHandlerHandleMethodInterceptor.java:96)
~[na:na]
at
reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.runFinally(FluxDoFinally.java:156)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
... 92 common frames omitted
2020-07-21 19:30:32.417 ERROR 33410 --- [ctor-http-nio-3]
reactor.core.publisher.Operators : Operator called default
onErrorDropped
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:314)
~[skywalking-agent.jar:8.0.1]
at
org.apache.skywalking.apm.plugin.spring.webflux.v5.DispatcherHandlerHandleMethodInterceptor.lambda$afterMethod$0(DispatcherHandlerHandleMethodInterceptor.java:96)
~[na:na]
at
reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.runFinally(FluxDoFinally.java:156)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.onComplete(FluxDoFinally.java:139)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:189)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:260)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:1713)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:189)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:260)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxPeek$PeekSubscriber.onComplete(FluxPeek.java:252)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
org.springframework.http.server.reactive.ChannelSendOperator$WriteCompletionBarrier.onComplete(ChannelSendOperator.java:374)
~[spring-web-5.1.3.RELEASE.jar:5.1.3.RELEASE]
at
reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:81)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxConcatIterable$ConcatIterableSubscriber.onComplete(FluxConcatIterable.java:120)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MonoSubscriber.onComplete(Operators.java:1516)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoIgnoreThen$ThenAcceptInner.onComplete(MonoIgnoreThen.java:314)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.netty.FutureMono$ChannelFutureSubscription.setSuccess(FutureMono.java:384)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
io.netty.channel.DefaultChannelPromise.setSuccess(DefaultChannelPromise.java:73)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
reactor.netty.channel.ChannelOperationsHandler$PublisherSender.operationComplete(ChannelOperationsHandler.java:733)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
reactor.netty.channel.ChannelOperationsHandler$PublisherSender.operationComplete(ChannelOperationsHandler.java:479)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
~[netty-common-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:485)
~[netty-common-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
~[netty-common-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.util.concurrent.DefaultPromise.addListener(DefaultPromise.java:162)
~[netty-common-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:95)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:30)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
reactor.netty.channel.ChannelOperationsHandler$PublisherSender.onComplete(ChannelOperationsHandler.java:587)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:136)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
org.springframework.http.server.reactive.ChannelSendOperator$WriteBarrier.onComplete(ChannelSendOperator.java:221)
~[spring-web-5.1.3.RELEASE.jar:5.1.3.RELEASE]
at
reactor.core.publisher.FluxJust$WeakScalarSubscription.request(FluxJust.java:101)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
org.springframework.http.server.reactive.ChannelSendOperator$WriteBarrier.onSubscribe(ChannelSendOperator.java:164)
~[spring-web-5.1.3.RELEASE.jar:5.1.3.RELEASE]
at reactor.core.publisher.FluxJust.subscribe(FluxJust.java:70)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
org.springframework.http.server.reactive.ChannelSendOperator.subscribe(ChannelSendOperator.java:75)
~[spring-web-5.1.3.RELEASE.jar:5.1.3.RELEASE]
at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:71)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:150)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:76)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxJust$WeakScalarSubscription.request(FluxJust.java:99)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.request(FluxMapFuseable.java:162)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoNext$NextSubscriber.request(MonoNext.java:102)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:1849)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:1723)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoNext$NextSubscriber.onSubscribe(MonoNext.java:64)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onSubscribe(FluxMapFuseable.java:90)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.FluxJust.subscribe(FluxJust.java:70)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxMapFuseable.subscribe(FluxMapFuseable.java:63)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoNext.subscribe(MonoNext.java:40)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoSwitchIfEmpty.subscribe(MonoSwitchIfEmpty.java:44)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:150)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1476)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapInner.onNext(MonoFlatMap.java:241)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:73)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:204)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:204)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1476)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoIgnoreThen$ThenAcceptInner.onNext(MonoIgnoreThen.java:296)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1476)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:144)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1476)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoZip$ZipCoordinator.signal(MonoZip.java:247)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoZip$ZipInner.onNext(MonoZip.java:329)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1476)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxDefaultIfEmpty$DefaultIfEmptySubscriber.onComplete(FluxDefaultIfEmpty.java:100)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:1713)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:144)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxContextStart$ContextStartSubscriber.onComplete(FluxContextStart.java:122)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxMapFuseable$MapFuseableConditionalSubscriber.onComplete(FluxMapFuseable.java:336)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxFilterFuseable$FilterFuseableConditionalSubscriber.onComplete(FluxFilterFuseable.java:385)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1479)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoCollectList$MonoBufferAllSubscriber.onComplete(MonoCollectList.java:118)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:136)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxPeek$PeekSubscriber.onComplete(FluxPeek.java:252)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:136)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.netty.channel.FluxReceive.terminateReceiver(FluxReceive.java:378)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:202)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
reactor.netty.channel.FluxReceive.onInboundComplete(FluxReceive.java:343)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
reactor.netty.channel.ChannelOperations.onInboundComplete(ChannelOperations.java:325)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
reactor.netty.http.server.HttpServerOperations.onInboundNext(HttpServerOperations.java:445)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:141)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
reactor.netty.http.server.HttpTrafficHandler.channelRead(HttpTrafficHandler.java:188)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:438)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
~[netty-codec-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297)
~[netty-codec-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:253)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:648)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:583)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:500)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:462)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:897)
~[netty-common-4.1.31.Final.jar:4.1.31.Final]
at java.base/java.lang.Thread.run(Thread.java:834) ~[na:na]
2020-07-21 19:30:32.420 WARN 33410 --- [ctor-http-nio-3]
io.netty.util.concurrent.DefaultPromise : An exception was thrown by
reactor.netty.channel.ChannelOperationsHandler$PublisherSender.operationComplete()
reactor.core.Exceptions$BubblingException: java.lang.RuntimeException: Can
not do async finish for the span repeatedly.
at reactor.core.Exceptions.bubble(Exceptions.java:154)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.Operators.onErrorDropped(Operators.java:512)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.runFinally(FluxDoFinally.java:159)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.onComplete(FluxDoFinally.java:139)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:189)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:260)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:1713)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapMain.secondComplete(MonoFlatMap.java:189)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapInner.onComplete(MonoFlatMap.java:260)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxPeek$PeekSubscriber.onComplete(FluxPeek.java:252)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
org.springframework.http.server.reactive.ChannelSendOperator$WriteCompletionBarrier.onComplete(ChannelSendOperator.java:374)
~[spring-web-5.1.3.RELEASE.jar:5.1.3.RELEASE]
at
reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.onComplete(MonoIgnoreElements.java:81)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxConcatIterable$ConcatIterableSubscriber.onComplete(FluxConcatIterable.java:120)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MonoSubscriber.onComplete(Operators.java:1516)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoIgnoreThen$ThenAcceptInner.onComplete(MonoIgnoreThen.java:314)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.netty.FutureMono$ChannelFutureSubscription.setSuccess(FutureMono.java:384)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
io.netty.channel.DefaultChannelPromise.setSuccess(DefaultChannelPromise.java:73)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
reactor.netty.channel.ChannelOperationsHandler$PublisherSender.operationComplete(ChannelOperationsHandler.java:733)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
reactor.netty.channel.ChannelOperationsHandler$PublisherSender.operationComplete(ChannelOperationsHandler.java:479)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
~[netty-common-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:485)
~[netty-common-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
~[netty-common-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.util.concurrent.DefaultPromise.addListener(DefaultPromise.java:162)
~[netty-common-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:95)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.DefaultChannelPromise.addListener(DefaultChannelPromise.java:30)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
reactor.netty.channel.ChannelOperationsHandler$PublisherSender.onComplete(ChannelOperationsHandler.java:587)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:136)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
org.springframework.http.server.reactive.ChannelSendOperator$WriteBarrier.onComplete(ChannelSendOperator.java:221)
~[spring-web-5.1.3.RELEASE.jar:5.1.3.RELEASE]
at
reactor.core.publisher.FluxJust$WeakScalarSubscription.request(FluxJust.java:101)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
org.springframework.http.server.reactive.ChannelSendOperator$WriteBarrier.onSubscribe(ChannelSendOperator.java:164)
~[spring-web-5.1.3.RELEASE.jar:5.1.3.RELEASE]
at reactor.core.publisher.FluxJust.subscribe(FluxJust.java:70)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
org.springframework.http.server.reactive.ChannelSendOperator.subscribe(ChannelSendOperator.java:75)
~[spring-web-5.1.3.RELEASE.jar:5.1.3.RELEASE]
at reactor.core.publisher.MonoPeek.subscribe(MonoPeek.java:71)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:150)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxSwitchIfEmpty$SwitchIfEmptySubscriber.onNext(FluxSwitchIfEmpty.java:67)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:76)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:121)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxJust$WeakScalarSubscription.request(FluxJust.java:99)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.request(FluxMapFuseable.java:162)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoNext$NextSubscriber.request(MonoNext.java:102)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MultiSubscriptionSubscriber.set(Operators.java:1849)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onSubscribe(Operators.java:1723)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoNext$NextSubscriber.onSubscribe(MonoNext.java:64)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onSubscribe(FluxMapFuseable.java:90)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.FluxJust.subscribe(FluxJust.java:70)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxMapFuseable.subscribe(FluxMapFuseable.java:63)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoNext.subscribe(MonoNext.java:40)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoSwitchIfEmpty.subscribe(MonoSwitchIfEmpty.java:44)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoOnErrorResume.subscribe(MonoOnErrorResume.java:44)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:150)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1476)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapInner.onNext(MonoFlatMap.java:241)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onNext(FluxOnErrorResume.java:73)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:204)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:204)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1476)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoIgnoreThen$ThenAcceptInner.onNext(MonoIgnoreThen.java:296)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1476)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:144)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1476)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoZip$ZipCoordinator.signal(MonoZip.java:247)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at reactor.core.publisher.MonoZip$ZipInner.onNext(MonoZip.java:329)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:192)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1476)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxDefaultIfEmpty$DefaultIfEmptySubscriber.onComplete(FluxDefaultIfEmpty.java:100)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MultiSubscriptionSubscriber.onComplete(Operators.java:1713)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onComplete(FluxMapFuseable.java:144)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxContextStart$ContextStartSubscriber.onComplete(FluxContextStart.java:122)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxMapFuseable$MapFuseableConditionalSubscriber.onComplete(FluxMapFuseable.java:336)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxFilterFuseable$FilterFuseableConditionalSubscriber.onComplete(FluxFilterFuseable.java:385)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1479)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.MonoCollectList$MonoBufferAllSubscriber.onComplete(MonoCollectList.java:118)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:136)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxPeek$PeekSubscriber.onComplete(FluxPeek.java:252)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.core.publisher.FluxMap$MapSubscriber.onComplete(FluxMap.java:136)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
at
reactor.netty.channel.FluxReceive.terminateReceiver(FluxReceive.java:378)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:202)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
reactor.netty.channel.FluxReceive.onInboundComplete(FluxReceive.java:343)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
reactor.netty.channel.ChannelOperations.onInboundComplete(ChannelOperations.java:325)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
reactor.netty.http.server.HttpServerOperations.onInboundNext(HttpServerOperations.java:445)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:141)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
reactor.netty.http.server.HttpTrafficHandler.channelRead(HttpTrafficHandler.java:188)
~[reactor-netty-0.8.3.RELEASE.jar:0.8.3.RELEASE]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.CombinedChannelDuplexHandler$DelegatingChannelHandlerContext.fireChannelRead(CombinedChannelDuplexHandler.java:438)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDecoder.java:323)
~[netty-codec-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:297)
~[netty-codec-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.CombinedChannelDuplexHandler.channelRead(CombinedChannelDuplexHandler.java:253)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:340)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1434)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:362)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:348)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:965)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:163)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:648)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:583)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:500)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:462)
~[netty-transport-4.1.31.Final.jar:4.1.31.Final]
at
io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:897)
~[netty-common-4.1.31.Final.jar:4.1.31.Final]
at java.base/java.lang.Thread.run(Thread.java:834) ~[na:na]
Caused by: 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:314)
~[skywalking-agent.jar:8.0.1]
at
org.apache.skywalking.apm.plugin.spring.webflux.v5.DispatcherHandlerHandleMethodInterceptor.lambda$afterMethod$0(DispatcherHandlerHandleMethodInterceptor.java:96)
~[na:na]
at
reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.runFinally(FluxDoFinally.java:156)
~[reactor-core-3.2.3.RELEASE.jar:3.2.3.RELEASE]
... 104 common frames omitted
```
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
