reactor.core.Exceptions$ErrorCallbackNotImplemented: java.lang.IllegalArgumentException: Cannot decode value of type class reactor.core.publisher.Mono for 253 with collation 45
Caused by: java.lang.IllegalArgumentException: Cannot decode value of type class reactor.core.publisher.Mono for 253 with collation 45
at dev.miku.r2dbc.mysql.codec.DefaultCodecs.decodeNormal(DefaultCodecs.java:212) ~[r2dbc-mysql-0.8.2.RELEASE.jar:0.8.2.RELEASE]
Suppressed: reactor.core.publisher.FluxOnAssembly$OnAssemblyException:
Assembly trace from producer [reactor.core.publisher.FluxHandleFuseable] :
reactor.core.publisher.Flux.handle(Flux.java:5556)
dev.miku.r2dbc.mysql.MySqlResult.map(MySqlResult.java:93)
Error has been observed at the following site(s):
|_ Flux.handle ⇢ at dev.miku.r2dbc.mysql.MySqlResult.map(MySqlResult.java:93)
|_ Flux.flatMap ⇢ at ht.ewx.batch.r2dbcibatis.impl.DefaultReactiveSqlSession.lambda$selectOne$2(DefaultReactiveSqlSession.java:66)
|_ Flux.last ⇢ at ht.ewx.batch.r2dbcibatis.impl.DefaultReactiveSqlSession.lambda$selectOne$2(DefaultReactiveSqlSession.java:67)
|_ Mono.flatMap ⇢ at ht.ewx.batch.r2dbcibatis.impl.DefaultReactiveSqlSession.selectOne(DefaultReactiveSqlSession.java:59)
|_ Mono.metrics ⇢ at ht.ewx.batch.r2dbcibatis.impl.DefaultReactiveSqlSession.selectOne(DefaultReactiveSqlSession.java:70)
|_ Mono.switchIfEmpty ⇢ at ht.ewx.batch.service.batch.CustomerReformService.lambda$analysisFollowers$7(CustomerReformService.java:128)
|_ Mono.zip ⇢ at ht.ewx.batch.service.batch.CustomerReformService.lambda$analysisFollowers$7(CustomerReformService.java:128)
|_ Mono.flatMap ⇢ at ht.ewx.batch.service.batch.CustomerReformService.lambda$analysisFollowers$7(CustomerReformService.java:130)
|_ Mono.zip ⇢ at ht.ewx.batch.service.batch.CustomerReformService.lambda$analysisFollowers$7(CustomerReformService.java:137)
|_ Flux.flatMap ⇢ at ht.ewx.batch.service.batch.CustomerReformService.analysisFollowers(CustomerReformService.java:95)
|_ Flux.flatMap ⇢ at ht.ewx.batch.service.batch.CustomerReformService.reFormingCustomerTags(CustomerReformService.java:70)
Stack trace:
at dev.miku.r2dbc.mysql.codec.DefaultCodecs.decodeNormal(DefaultCodecs.java:212) ~[r2dbc-mysql-0.8.2.RELEASE.jar:0.8.2.RELEASE]
at dev.miku.r2dbc.mysql.codec.DefaultCodecs.decode(DefaultCodecs.java:105) ~[r2dbc-mysql-0.8.2.RELEASE.jar:0.8.2.RELEASE]
at dev.miku.r2dbc.mysql.MySqlRow.get(MySqlRow.java:59) ~[r2dbc-mysql-0.8.2.RELEASE.jar:0.8.2.RELEASE]
at ht.ewx.batch.r2dbcibatis.impl.DefaultReactiveSqlSession.convertRowToResult(DefaultReactiveSqlSession.java:263) ~[main/:na]
at ht.ewx.batch.r2dbcibatis.impl.DefaultReactiveSqlSession.lambda$null$0(DefaultReactiveSqlSession.java:66) ~[main/:na]
at dev.miku.r2dbc.mysql.MySqlResult.processRow(MySqlResult.java:176) ~[r2dbc-mysql-0.8.2.RELEASE.jar:0.8.2.RELEASE]
at dev.miku.r2dbc.mysql.MySqlResult.handleResult(MySqlResult.java:149) ~[r2dbc-mysql-0.8.2.RELEASE.jar:0.8.2.RELEASE]
at dev.miku.r2dbc.mysql.MySqlResult.lambda$map$1(MySqlResult.java:93) ~[r2dbc-mysql-0.8.2.RELEASE.jar:0.8.2.RELEASE]
at reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.onNext(FluxHandleFuseable.java:169) ~[reactor-core-3.4.0.jar:3.4.0]
at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onNext(FluxContextWrite.java:107) ~[reactor-core-3.4.0.jar:3.4.0]
at dev.miku.r2dbc.mysql.util.DiscardOnCancelSubscriber.onNext(DiscardOnCancelSubscriber.java:70) ~[r2dbc-mysql-0.8.2.RELEASE.jar:0.8.2.RELEASE]
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drainRegular(FluxWindowPredicate.java:657) ~[reactor-core-3.4.0.jar:3.4.0]
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.drain(FluxWindowPredicate.java:735) ~[reactor-core-3.4.0.jar:3.4.0]
at reactor.core.publisher.FluxWindowPredicate$WindowFlux.onNext(FluxWindowPredicate.java:777) ~[reactor-core-3.4.0.jar:3.4.0]
at reactor.core.publisher.FluxWindowPredicate$WindowPredicateMain.onNext(FluxWindowPredicate.java:255) ~[reactor-core-3.4.0.jar:3.4.0]
at reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.onNext(FluxHandleFuseable.java:184) ~[reactor-core-3.4.0.jar:3.4.0]
at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.onNext(FluxContextWrite.java:107) ~[reactor-core-3.4.0.jar:3.4.0]
at dev.miku.r2dbc.mysql.util.DiscardOnCancelSubscriber.onNext(DiscardOnCancelSubscriber.java:70) ~[r2dbc-mysql-0.8.2.RELEASE.jar:0.8.2.RELEASE]
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableConditionalSubscriber.onNext(FluxPeekFuseable.java:503) ~[reactor-core-3.4.0.jar:3.4.0]
at reactor.core.publisher.MonoFlatMapMany$FlatMapManyInner.onNext(MonoFlatMapMany.java:250) ~[reactor-core-3.4.0.jar:3.4.0]
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onNext(FluxPeekFuseable.java:210) ~[reactor-core-3.4.0.jar:3.4.0]
at reactor.core.publisher.FluxHandleFuseable$HandleFuseableSubscriber.onNext(FluxHandleFuseable.java:184) ~[reactor-core-3.4.0.jar:3.4.0]
at reactor.core.publisher.FluxPeekFuseable$PeekConditionalSubscriber.onNext(FluxPeekFuseable.java:854) [reactor-core-3.4.0.jar:3.4.0]
at reactor.core.publisher.EmitterProcessor.drain(EmitterProcessor.java:478) [reactor-core-3.4.0.jar:3.4.0]
at reactor.core.publisher.EmitterProcessor.tryEmitNext(EmitterProcessor.java:286) [reactor-core-3.4.0.jar:3.4.0]
at reactor.core.publisher.InternalManySink.emitNext(InternalManySink.java:27) [reactor-core-3.4.0.jar:3.4.0]
at reactor.core.publisher.EmitterProcessor.onNext(EmitterProcessor.java:252) [reactor-core-3.4.0.jar:3.4.0]
at dev.miku.r2dbc.mysql.client.ReactorNettyClient$ResponseSink.next(ReactorNettyClient.java:340) [r2dbc-mysql-0.8.2.RELEASE.jar:0.8.2.RELEASE]
at dev.miku.r2dbc.mysql.client.ReactorNettyClient.lambda$new$0(ReactorNettyClient.java:103) [r2dbc-mysql-0.8.2.RELEASE.jar:0.8.2.RELEASE]
at reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:184) ~[reactor-core-3.4.0.jar:3.4.0]
at reactor.netty.channel.FluxReceive.drainReceiver(FluxReceive.java:256) ~[reactor-netty-core-1.0.0.jar:1.0.0]
at reactor.netty.channel.FluxReceive.onInboundNext(FluxReceive.java:362) ~[reactor-netty-core-1.0.0.jar:1.0.0]
at reactor.netty.channel.ChannelOperations.onInboundNext(ChannelOperations.java:383) ~[reactor-netty-core-1.0.0.jar:1.0.0]
at reactor.netty.channel.ChannelOperationsHandler.channelRead(ChannelOperationsHandler.java:94) ~[reactor-netty-core-1.0.0.jar:1.0.0]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) ~[netty-all-4.1.53.Final.jar:4.1.53.Final]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:365) ~[netty-all-4.1.53.Final.jar:4.1.53.Final]
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:357) ~[netty-all-4.1.53.Final.jar:4.1.53.Final]
at dev.miku.r2dbc.mysql.client.MessageDuplexCodec.handleDecoded(MessageDuplexCodec.java:187) ~[r2dbc-mysql-0.8.2.RELEASE.jar:0.8.2.RELEASE]
at dev.miku.r2dbc.mysql.client.MessageDuplexCodec.channelRead(MessageDuplexCodec.java:95) ~[r2dbc-mysql-0.8.2.RELEASE.jar:0.8.2.RELEASE]
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:379) ~[netty-all-4.1.53.Final.jar:4.1.53.