Describe the bug
It appears when a subscriber cancels a subscription the cosmos db library attempts to cancel the stream and then create a new subscription to do some maintenance and inform the service. At that point the subscription fail with a CancellationException.
Exception or Stack Trace
Report this azure-cosmos-4.37.1.jar issue to ensure it is addressed:
[RntbdServiceEndpoint({"id":3581,"closed":false,"concurrentRequests":1,"remoteAddress":"cdb-ms-prod-centralus1-be12.documents.azure.com/:14351","channelPool":{"remoteAddress":"cdb-ms-prod-centralus1-be12.documents.azure.com/:14351","isClosed":false,"configuration":{"maxChannels":130,"maxRequestsPerChannel":30,"idleConnectionTimeout":0,"readDelayLimit":65000000000,"writeDelayLimit":10000000000},"state":{"channelsAcquired":1,"channelsAvailable":0,"requestQueueLength":0}},"transportClient":{"id":1,"closed":false,"endpointCount":3594,"endpointEvictionCount":2}})]
[com.azure.cosmos.implementation.directconnectivity.RntbdTransportClient.lambda$invokeStoreAsync$2(RntbdTransportClient.java:266)]
[request completed with an unexpected class java.util.concurrent.CancellationException: {"record":AsyncRntbdRequestRecord({"args":{"transportRequestId":1062022,"activityId":"47c33018-5149-11ed-9a59-b96b47177f2d","origin":"rntbd://cdb-ms-prod-centralus1-be12.documents.azure.com:14351","replicaPath":"/apps/c7342e1d-0cc8-445a-b839-463a8401d601/services/c1276289-e70a-4f7b-9063-6944f5f1e6ea/partitions/eeb71e88-510f-43a2-a40c-960febec1664/replicas/133073013074699057p","timeCreated":"2022-10-21T14:04:29.679755546Z","lifetime":"PT0.053937984S"},"requestLength":-1,"responseLength":-1,"status":{"done":false,"cancelled":false,"completedExceptionally":false},"timeline":[{"eventName":"created","startTimeUTC":"2022-10-21T14:04:29.679755546Z","durationInMilliSecs":0.0044},{"eventName":"queued","startTimeUTC":"2022-10-21T14:04:29.679759946Z","durationInMilliSecs":1.0E-4},{"eventName":"channelAcquisitionStarted","startTimeUTC":"2022-10-21T14:04:29.679760046Z","durationInMilliSecs":17.639925},{"eventName":"pipelined","startTimeUTC":"2022-10-21T14:04:29.697399971Z","durationInMilliSecs":36.314059},{"eventName":"transitTime","startTimeUTC":null,"durationInMilliSecs":0.0},{"eventName":"decodeTime","startTimeUTC":null,"durationInMilliSecs":0.0},{"eventName":"received","startTimeUTC":null,"durationInMilliSecs":0.0},{"eventName":"completed","startTimeUTC":null,"durationInMilliSecs":0.0}]}),"error":{"cause":null,"stackTrace":[{"classLoaderName":null,"moduleName":"java.base","moduleVersion":"16.0.2","methodName":"cancel","fileName":"CompletableFuture.java","lineNumber":2474,"nativeMethod":false,"className":"java.util.concurrent.CompletableFuture"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"MonoCompletionStage.java","lineNumber":56,"nativeMethod":false,"className":"reactor.core.publisher.MonoCompletionStage$1"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainLoop","fileName":"Operators.java","lineNumber":2252,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drain","fileName":"Operators.java","lineNumber":2220,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2032,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxDoFinally.java","lineNumber":134,"nativeMethod":false,"className":"reactor.core.publisher.FluxDoFinally$DoFinallySubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxContextWrite.java","lineNumber":141,"nativeMethod":false,"className":"reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxFlatMap.java","lineNumber":359,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainLoop","fileName":"Operators.java","lineNumber":2252,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drain","fileName":"Operators.java","lineNumber":2220,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2032,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"terminate","fileName":"Operators.java","lineNumber":1240,"nativeMethod":false,"className":"reactor.core.publisher.Operators"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxFlatMap.java","lineNumber":1022,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapInner"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"unsubscribeEntry","fileName":"FluxFlatMap.java","lineNumber":340,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"unsubscribeEntry","fileName":"FluxFlatMap.java","lineNumber":219,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"unsubscribe","fileName":"FluxFlatMap.java","lineNumber":1083,"nativeMethod":false,"className":"reactor.core.publisher.FlatMapTracker"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxFlatMap.java","lineNumber":360,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"MonoCollectList.java","lineNumber":144,"nativeMethod":false,"className":"reactor.core.publisher.MonoCollectList$MonoCollectListSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainLoop","fileName":"Operators.java","lineNumber":2252,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drain","fileName":"Operators.java","lineNumber":2220,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2032,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMap.java","lineNumber":169,"nativeMethod":false,"className":"reactor.core.publisher.FluxMap$MapSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainLoop","fileName":"Operators.java","lineNumber":2252,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drain","fileName":"Operators.java","lineNumber":2220,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2032,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxTakeUntil.java","lineNumber":146,"nativeMethod":false,"className":"reactor.core.publisher.FluxTakeUntil$TakeUntilPredicateSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"MonoIgnoreElements.java","lineNumber":104,"nativeMethod":false,"className":"reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxConcatArray.java","lineNumber":286,"nativeMethod":false,"className":"reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainLoop","fileName":"Operators.java","lineNumber":2252,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drain","fileName":"Operators.java","lineNumber":2220,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2032,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"terminate","fileName":"Operators.java","lineNumber":1240,"nativeMethod":false,"className":"reactor.core.publisher.Operators"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxFlatMap.java","lineNumber":1022,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapInner"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"unsubscribeEntry","fileName":"FluxFlatMap.java","lineNumber":340,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"unsubscribeEntry","fileName":"FluxFlatMap.java","lineNumber":219,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"unsubscribe","fileName":"FluxFlatMap.java","lineNumber":1083,"nativeMethod":false,"className":"reactor.core.publisher.FlatMapTracker"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxFlatMap.java","lineNumber":360,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"doOnCancel","fileName":"MonoSingle.java","lineNumber":108,"nativeMethod":false,"className":"reactor.core.publisher.MonoSingle$SingleSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2784,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MonoInnerProducerBase"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"terminate","fileName":"Operators.java","lineNumber":1240,"nativeMethod":false,"className":"reactor.core.publisher.Operators"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"MonoFlatMap.java","lineNumber":187,"nativeMethod":false,"className":"reactor.core.publisher.MonoFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxPeekFuseable.java","lineNumber":159,"nativeMethod":false,"className":"reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"doOnCancel","fileName":"MonoSingle.java","lineNumber":108,"nativeMethod":false,"className":"reactor.core.publisher.MonoSingle$SingleSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2784,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MonoInnerProducerBase"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"terminate","fileName":"Operators.java","lineNumber":1240,"nativeMethod":false,"className":"reactor.core.publisher.Operators"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"MonoFlatMap.java","lineNumber":187,"nativeMethod":false,"className":"reactor.core.publisher.MonoFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainLoop","fileName":"Operators.java","lineNumber":2252,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drain","fileName":"Operators.java","lineNumber":2220,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2032,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxRetryWhen.java","lineNumber":163,"nativeMethod":false,"className":"reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"SerializedSubscriber.java","lineNumber":157,"nativeMethod":false,"className":"reactor.core.publisher.SerializedSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainLoop","fileName":"Operators.java","lineNumber":2252,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drain","fileName":"Operators.java","lineNumber":2220,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2032,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"MonoPeekTerminal.java","lineNumber":144,"nativeMethod":false,"className":"reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"terminate","fileName":"Operators.java","lineNumber":1240,"nativeMethod":false,"className":"reactor.core.publisher.Operators"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"MonoFlatMap.java","lineNumber":187,"nativeMethod":false,"className":"reactor.core.publisher.MonoFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMapFuseable.java","lineNumber":176,"nativeMethod":false,"className":"reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"terminate","fileName":"Operators.java","lineNumber":1240,"nativeMethod":false,"className":"reactor.core.publisher.Operators"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"MonoFlatMap.java","lineNumber":272,"nativeMethod":false,"className":"reactor.core.publisher.MonoFlatMap$FlatMapInner"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"MonoFlatMap.java","lineNumber":188,"nativeMethod":false,"className":"reactor.core.publisher.MonoFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"doOnCancel","fileName":"MonoSingle.java","lineNumber":108,"nativeMethod":false,"className":"reactor.core.publisher.MonoSingle$SingleSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2784,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MonoInnerProducerBase"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMap.java","lineNumber":169,"nativeMethod":false,"className":"reactor.core.publisher.FluxMap$MapSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainLoop","fileName":"Operators.java","lineNumber":2252,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drain","fileName":"Operators.java","lineNumber":2220,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2032,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxRetryWhen.java","lineNumber":163,"nativeMethod":false,"className":"reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"SerializedSubscriber.java","lineNumber":157,"nativeMethod":false,"className":"reactor.core.publisher.SerializedSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMap.java","lineNumber":169,"nativeMethod":false,"className":"reactor.core.publisher.FluxMap$MapSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"set","fileName":"Operators.java","lineNumber":1160,"nativeMethod":false,"className":"reactor.core.publisher.Operators"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMergeSequential.java","lineNumber":601,"nativeMethod":false,"className":"reactor.core.publisher.FluxMergeSequential$MergeSequentialInner"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancelAll","fileName":"FluxMergeSequential.java","lineNumber":285,"nativeMethod":false,"className":"reactor.core.publisher.FluxMergeSequential$MergeSequentialMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainAndCancel","fileName":"FluxMergeSequential.java","lineNumber":276,"nativeMethod":false,"className":"reactor.core.publisher.FluxMergeSequential$MergeSequentialMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMergeSequential.java","lineNumber":270,"nativeMethod":false,"className":"reactor.core.publisher.FluxMergeSequential$MergeSequentialMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMap.java","lineNumber":169,"nativeMethod":false,"className":"reactor.core.publisher.FluxMap$MapSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMap.java","lineNumber":169,"nativeMethod":false,"className":"reactor.core.publisher.FluxMap$MapSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainLoop","fileName":"Operators.java","lineNumber":2252,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drain","fileName":"Operators.java","lineNumber":2220,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2032,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"set","fileName":"Operators.java","lineNumber":1160,"nativeMethod":false,"className":"reactor.core.publisher.Operators"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMergeSequential.java","lineNumber":601,"nativeMethod":false,"className":"reactor.core.publisher.FluxMergeSequential$MergeSequentialInner"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancelAll","fileName":"FluxMergeSequential.java","lineNumber":285,"nativeMethod":false,"className":"reactor.core.publisher.FluxMergeSequential$MergeSequentialMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainAndCancel","fileName":"FluxMergeSequential.java","lineNumber":276,"nativeMethod":false,"className":"reactor.core.publisher.FluxMergeSequential$MergeSequentialMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMergeSequential.java","lineNumber":270,"nativeMethod":false,"className":"reactor.core.publisher.FluxMergeSequential$MergeSequentialMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxFilter.java","lineNumber":191,"nativeMethod":false,"className":"reactor.core.publisher.FluxFilter$FilterSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMap.java","lineNumber":169,"nativeMethod":false,"className":"reactor.core.publisher.FluxMap$MapSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxConcatArray.java","lineNumber":286,"nativeMethod":false,"className":"reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMap.java","lineNumber":169,"nativeMethod":false,"className":"reactor.core.publisher.FluxMap$MapSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxSkip.java","lineNumber":126,"nativeMethod":false,"className":"reactor.core.publisher.FluxSkip$SkipSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMap.java","lineNumber":169,"nativeMethod":false,"className":"reactor.core.publisher.FluxMap$MapSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMap.java","lineNumber":169,"nativeMethod":false,"className":"reactor.core.publisher.FluxMap$MapSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainLoop","fileName":"Operators.java","lineNumber":2252,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drain","fileName":"Operators.java","lineNumber":2220,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2032,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMap.java","lineNumber":169,"nativeMethod":false,"className":"reactor.core.publisher.FluxMap$MapSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"terminate","fileName":"Operators.java","lineNumber":1240,"nativeMethod":false,"className":"reactor.core.publisher.Operators"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxFlatMap.java","lineNumber":1022,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapInner"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"unsubscribeEntry","fileName":"FluxFlatMap.java","lineNumber":340,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"unsubscribeEntry","fileName":"FluxFlatMap.java","lineNumber":219,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"unsubscribe","fileName":"FluxFlatMap.java","lineNumber":1083,"nativeMethod":false,"className":"reactor.core.publisher.FlatMapTracker"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxFlatMap.java","lineNumber":360,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainLoop","fileName":"Operators.java","lineNumber":2252,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drain","fileName":"Operators.java","lineNumber":2220,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2032,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxRetryWhen.java","lineNumber":163,"nativeMethod":false,"className":"reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"SerializedSubscriber.java","lineNumber":157,"nativeMethod":false,"className":"reactor.core.publisher.SerializedSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMap.java","lineNumber":169,"nativeMethod":false,"className":"reactor.core.publisher.FluxMap$MapSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxPeek.java","lineNumber":153,"nativeMethod":false,"className":"reactor.core.publisher.FluxPeek$PeekSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxDoOnEach.java","lineNumber":113,"nativeMethod":false,"className":"reactor.core.publisher.FluxDoOnEach$DoOnEachSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"terminate","fileName":"Operators.java","lineNumber":1240,"nativeMethod":false,"className":"reactor.core.publisher.Operators"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"StrictSubscriber.java","lineNumber":155,"nativeMethod":false,"className":"reactor.core.publisher.StrictSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"$anonfun$fsm$19","fileName":"StreamSubscriber.scala","lineNumber":196,"nativeMethod":false,"className":"fs2.interop.reactivestreams.StreamSubscriber$"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"nextState","fileName":"StreamSubscriber.scala","lineNumber":215,"nativeMethod":false,"className":"fs2.interop.reactivestreams.StreamSubscriber$$anon$1"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"$anonfun$onFinalize$1","fileName":"StreamSubscriber.scala","lineNumber":221,"nativeMethod":false,"className":"fs2.interop.reactivestreams.StreamSubscriber$$anon$1"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"apply","fileName":"JFunction0$mcV$sp.scala","lineNumber":18,"nativeMethod":false,"className":"scala.runtime.java8.JFunction0$mcV$sp"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"runLoop","fileName":"IOFiber.scala","lineNumber":283,"nativeMethod":false,"className":"cats.effect.IOFiber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"asyncContinueSuccessfulR","fileName":"IOFiber.scala","lineNumber":1338,"nativeMethod":false,"className":"cats.effect.IOFiber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"run","fileName":"IOFiber.scala","lineNumber":140,"nativeMethod":false,"className":"cats.effect.IOFiber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"run","fileName":"WorkerThread.scala","lineNumber":549,"nativeMethod":false,"className":"cats.effect.unsafe.WorkerThread"}],"message":null,"suppressed":[],"localizedMessage":null}}: com.azure.core.exception.AzureException
at com.azure.cosmos.implementation.directconnectivity.rntbd.RntbdReporter.doReportIssue(RntbdReporter.java:66)
at com.azure.cosmos.implementation.directconnectivity.rntbd.RntbdReporter.reportIssue(RntbdReporter.java:43)
at com.azure.cosmos.implementation.directconnectivity.RntbdTransportClient.lambda$invokeStoreAsync$2(RntbdTransportClient.java:266)
at reactor.core.publisher.Mono.lambda$onErrorMap$31(Mono.java:3776)
at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:94)
at reactor.core.publisher.MonoCompletionStage.lambda$subscribe$0(MonoCompletionStage.java:89)
at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
at java.base/java.util.concurrent.CompletableFuture.uniWhenCompleteStage(CompletableFuture.java:883)
at java.base/java.util.concurrent.CompletableFuture.whenComplete(CompletableFuture.java:2321)
at java.base/java.util.concurrent.CompletableFuture.whenComplete(CompletableFuture.java:143)
at reactor.core.publisher.MonoCompletionStage.subscribe(MonoCompletionStage.java:67)
at reactor.core.publisher.Mono.subscribe(Mono.java:4455)
at reactor.core.publisher.Mono.subscribeWith(Mono.java:4570)
at reactor.core.publisher.Mono.subscribe(Mono.java:4422)
at reactor.core.publisher.Mono.subscribe(Mono.java:4358)
at reactor.core.publisher.Mono.subscribe(Mono.java:4330)
at com.azure.cosmos.implementation.directconnectivity.RntbdTransportClient.lambda$invokeStoreAsync$5(RntbdTransportClient.java:329)
at reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.runFinally(FluxDoFinally.java:146)
at reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.cancel(FluxDoFinally.java:135)
at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.cancel(FluxContextWrite.java:141)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.cancel(FluxFlatMap.java:359)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drainLoop(Operators.java:2252)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drain(Operators.java:2220)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.cancel(Operators.java:2032)
at reactor.core.publisher.Operators.terminate(Operators.java:1240)
at reactor.core.publisher.FluxFlatMap$FlatMapInner.cancel(FluxFlatMap.java:1022)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.unsubscribeEntry(FluxFlatMap.java:340)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.unsubscribeEntry(FluxFlatMap.java:219)
at reactor.core.publisher.FlatMapTracker.unsubscribe(FluxFlatMap.java:1083)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.cancel(FluxFlatMap.java:360)
at reactor.core.publisher.MonoCollectList$MonoCollectListSubscriber.cancel(MonoCollectList.java:144)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drainLoop(Operators.java:2252)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drain(Operators.java:2220)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.cancel(Operators.java:2032)
at reactor.core.publisher.FluxMap$MapSubscriber.cancel(FluxMap.java:169)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drainLoop(Operators.java:2252)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drain(Operators.java:2220)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.cancel(Operators.java:2032)
at reactor.core.publisher.FluxTakeUntil$TakeUntilPredicateSubscriber.cancel(FluxTakeUntil.java:146)
at reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.cancel(MonoIgnoreElements.java:104)
at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.cancel(FluxConcatArray.java:286)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drainLoop(Operators.java:2252)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drain(Operators.java:2220)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.cancel(Operators.java:2032)
at reactor.core.publisher.Operators.terminate(Operators.java:1240)
at reactor.core.publisher.FluxFlatMap$FlatMapInner.cancel(FluxFlatMap.java:1022)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.unsubscribeEntry(FluxFlatMap.java:340)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.unsubscribeEntry(FluxFlatMap.java:219)
at reactor.core.publisher.FlatMapTracker.unsubscribe(FluxFlatMap.java:1083)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.cancel(FluxFlatMap.java:360)
at reactor.core.publisher.MonoSingle$SingleSubscriber.doOnCancel(MonoSingle.java:108)
at reactor.core.publisher.Operators$MonoInnerProducerBase.cancel(Operators.java:2784)
at reactor.core.publisher.Operators.terminate(Operators.java:1240)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.cancel(MonoFlatMap.java:187)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.cancel(FluxPeekFuseable.java:159)
at reactor.core.publisher.MonoSingle$SingleSubscriber.doOnCancel(MonoSingle.java:108)
at reactor.core.publisher.Operators$MonoInnerProducerBase.cancel(Operators.java:2784)
at reactor.core.publisher.Operators.terminate(Operators.java:1240)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.cancel(MonoFlatMap.java:187)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drainLoop(Operators.java:2252)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drain(Operators.java:2220)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.cancel(Operators.java:2032)
at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.cancel(FluxRetryWhen.java:163)
at reactor.core.publisher.SerializedSubscriber.cancel(SerializedSubscriber.java:157)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drainLoop(Operators.java:2252)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drain(Operators.java:2220)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.cancel(Operators.java:2032)
at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.cancel(MonoPeekTerminal.java:144)
at reactor.core.publisher.Operators.terminate(Operators.java:1240)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.cancel(MonoFlatMap.java:187)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.cancel(FluxMapFuseable.java:176)
at reactor.core.publisher.Operators.terminate(Operators.java:1240)
at reactor.core.publisher.MonoFlatMap$FlatMapInner.cancel(MonoFlatMap.java:272)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.cancel(MonoFlatMap.java:188)
at reactor.core.publisher.MonoSingle$SingleSubscriber.doOnCancel(MonoSingle.java:108)
at reactor.core.publisher.Operators$MonoInnerProducerBase.cancel(Operators.java:2784)
at reactor.core.publisher.FluxMap$MapSubscriber.cancel(FluxMap.java:169)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drainLoop(Operators.java:2252)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drain(Operators.java:2220)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.cancel(Operators.java:2032)
at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.cancel(FluxRetryWhen.java:163)
at reactor.core.publisher.SerializedSubscriber.cancel(SerializedSubscriber.java:157)
at reactor.core.publisher.FluxMap$MapSubscriber.cancel(FluxMap.java:169)
at reactor.core.publisher.Operators.set(Operators.java:1160)
at reactor.core.publisher.FluxMergeSequential$MergeSequentialInner.cancel(FluxMergeSequential.java:601)
at reactor.core.publisher.FluxMergeSequential$MergeSequentialMain.cancelAll(FluxMergeSequential.java:285)
at reactor.core.publisher.FluxMergeSequential$MergeSequentialMain.drainAndCancel(FluxMergeSequential.java:276)
at reactor.core.publisher.FluxMergeSequential$MergeSequentialMain.cancel(FluxMergeSequential.java:270)
at reactor.core.publisher.FluxMap$MapSubscriber.cancel(FluxMap.java:169)
at reactor.core.publisher.FluxMap$MapSubscriber.cancel(FluxMap.java:169)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drainLoop(Operators.java:2252)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drain(Operators.java:2220)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.cancel(Operators.java:2032)
at reactor.core.publisher.Operators.set(Operators.java:1160)
at reactor.core.publisher.FluxMergeSequential$MergeSequentialInner.cancel(FluxMergeSequential.java:601)
at reactor.core.publisher.FluxMergeSequential$MergeSequentialMain.cancelAll(FluxMergeSequential.java:285)
at reactor.core.publisher.FluxMergeSequential$MergeSequentialMain.drainAndCancel(FluxMergeSequential.java:276)
at reactor.core.publisher.FluxMergeSequential$MergeSequentialMain.cancel(FluxMergeSequential.java:270)
at reactor.core.publisher.FluxFilter$FilterSubscriber.cancel(FluxFilter.java:191)
at reactor.core.publisher.FluxMap$MapSubscriber.cancel(FluxMap.java:169)
at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.cancel(FluxConcatArray.java:286)
at reactor.core.publisher.FluxMap$MapSubscriber.cancel(FluxMap.java:169)
at reactor.core.publisher.FluxSkip$SkipSubscriber.cancel(FluxSkip.java:126)
at reactor.core.publisher.FluxMap$MapSubscriber.cancel(FluxMap.java:169)
at reactor.core.publisher.FluxMap$MapSubscriber.cancel(FluxMap.java:169)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drainLoop(Operators.java:2252)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drain(Operators.java:2220)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.cancel(Operators.java:2032)
at reactor.core.publisher.FluxMap$MapSubscriber.cancel(FluxMap.java:169)
at reactor.core.publisher.Operators.terminate(Operators.java:1240)
at reactor.core.publisher.FluxFlatMap$FlatMapInner.cancel(FluxFlatMap.java:1022)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.unsubscribeEntry(FluxFlatMap.java:340)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.unsubscribeEntry(FluxFlatMap.java:219)
at reactor.core.publisher.FlatMapTracker.unsubscribe(FluxFlatMap.java:1083)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.cancel(FluxFlatMap.java:360)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drainLoop(Operators.java:2252)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drain(Operators.java:2220)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.cancel(Operators.java:2032)
at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.cancel(FluxRetryWhen.java:163)
at reactor.core.publisher.SerializedSubscriber.cancel(SerializedSubscriber.java:157)
at reactor.core.publisher.FluxMap$MapSubscriber.cancel(FluxMap.java:169)
at reactor.core.publisher.FluxPeek$PeekSubscriber.cancel(FluxPeek.java:153)
at reactor.core.publisher.FluxDoOnEach$DoOnEachSubscriber.cancel(FluxDoOnEach.java:113)
at reactor.core.publisher.Operators.terminate(Operators.java:1240)
at reactor.core.publisher.StrictSubscriber.cancel(StrictSubscriber.java:155)
at fs2.interop.reactivestreams.StreamSubscriber$.$anonfun$fsm$19(StreamSubscriber.scala:196)
at fs2.interop.reactivestreams.StreamSubscriber$$anon$1.nextState(StreamSubscriber.scala:215)
at fs2.interop.reactivestreams.StreamSubscriber$$anon$1.$anonfun$onFinalize$1(StreamSubscriber.scala:221)
at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.scala:18)
at cats.effect.IOFiber.runLoop(IOFiber.scala:283)
at cats.effect.IOFiber.asyncContinueSuccessfulR(IOFiber.scala:1338)
at cats.effect.IOFiber.run(IOFiber.scala:140)
at cats.effect.unsafe.WorkerThread.run(WorkerThread.scala:549)
]
To Reproduce
Steps to reproduce the behavior: Unknown. This behavior appears when upgrading from 4.36.0 to 4.37.1. I also see this behavior with 4.38.0.
Code Snippet
Add the code snippet that causes the issue.
Expected behavior
A clear and concise description of what you expected to happen.
Screenshots
If applicable, add screenshots to help explain your problem.
Setup (please complete the following information):
- OS: linux
- Library/Libraries: com.azure:azure-cosmos:4.37.1
- Java version: 16
- App Server/Environment: kubernetes
- Frameworks: fs2
Information Checklist
Kindly make sure that you have added all the following information above and checkoff the required fields otherwise we will treat the issuer as an incomplete report
- [✅] Bug Description Added
- [✅] Repro Steps Added
- [✅] Setup information Added
Describe the bug
It appears when a subscriber cancels a subscription the cosmos db library attempts to cancel the stream and then create a new subscription to do some maintenance and inform the service. At that point the subscription fail with a CancellationException.
Exception or Stack Trace
Report this azure-cosmos-4.37.1.jar issue to ensure it is addressed:
[RntbdServiceEndpoint({"id":3581,"closed":false,"concurrentRequests":1,"remoteAddress":"cdb-ms-prod-centralus1-be12.documents.azure.com/:14351","channelPool":{"remoteAddress":"cdb-ms-prod-centralus1-be12.documents.azure.com/:14351","isClosed":false,"configuration":{"maxChannels":130,"maxRequestsPerChannel":30,"idleConnectionTimeout":0,"readDelayLimit":65000000000,"writeDelayLimit":10000000000},"state":{"channelsAcquired":1,"channelsAvailable":0,"requestQueueLength":0}},"transportClient":{"id":1,"closed":false,"endpointCount":3594,"endpointEvictionCount":2}})]
[com.azure.cosmos.implementation.directconnectivity.RntbdTransportClient.lambda$invokeStoreAsync$2(RntbdTransportClient.java:266)]
[request completed with an unexpected class java.util.concurrent.CancellationException: {"record":AsyncRntbdRequestRecord({"args":{"transportRequestId":1062022,"activityId":"47c33018-5149-11ed-9a59-b96b47177f2d","origin":"rntbd://cdb-ms-prod-centralus1-be12.documents.azure.com:14351","replicaPath":"/apps/c7342e1d-0cc8-445a-b839-463a8401d601/services/c1276289-e70a-4f7b-9063-6944f5f1e6ea/partitions/eeb71e88-510f-43a2-a40c-960febec1664/replicas/133073013074699057p","timeCreated":"2022-10-21T14:04:29.679755546Z","lifetime":"PT0.053937984S"},"requestLength":-1,"responseLength":-1,"status":{"done":false,"cancelled":false,"completedExceptionally":false},"timeline":[{"eventName":"created","startTimeUTC":"2022-10-21T14:04:29.679755546Z","durationInMilliSecs":0.0044},{"eventName":"queued","startTimeUTC":"2022-10-21T14:04:29.679759946Z","durationInMilliSecs":1.0E-4},{"eventName":"channelAcquisitionStarted","startTimeUTC":"2022-10-21T14:04:29.679760046Z","durationInMilliSecs":17.639925},{"eventName":"pipelined","startTimeUTC":"2022-10-21T14:04:29.697399971Z","durationInMilliSecs":36.314059},{"eventName":"transitTime","startTimeUTC":null,"durationInMilliSecs":0.0},{"eventName":"decodeTime","startTimeUTC":null,"durationInMilliSecs":0.0},{"eventName":"received","startTimeUTC":null,"durationInMilliSecs":0.0},{"eventName":"completed","startTimeUTC":null,"durationInMilliSecs":0.0}]}),"error":{"cause":null,"stackTrace":[{"classLoaderName":null,"moduleName":"java.base","moduleVersion":"16.0.2","methodName":"cancel","fileName":"CompletableFuture.java","lineNumber":2474,"nativeMethod":false,"className":"java.util.concurrent.CompletableFuture"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"MonoCompletionStage.java","lineNumber":56,"nativeMethod":false,"className":"reactor.core.publisher.MonoCompletionStage$1"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainLoop","fileName":"Operators.java","lineNumber":2252,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drain","fileName":"Operators.java","lineNumber":2220,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2032,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxDoFinally.java","lineNumber":134,"nativeMethod":false,"className":"reactor.core.publisher.FluxDoFinally$DoFinallySubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxContextWrite.java","lineNumber":141,"nativeMethod":false,"className":"reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxFlatMap.java","lineNumber":359,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainLoop","fileName":"Operators.java","lineNumber":2252,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drain","fileName":"Operators.java","lineNumber":2220,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2032,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"terminate","fileName":"Operators.java","lineNumber":1240,"nativeMethod":false,"className":"reactor.core.publisher.Operators"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxFlatMap.java","lineNumber":1022,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapInner"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"unsubscribeEntry","fileName":"FluxFlatMap.java","lineNumber":340,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"unsubscribeEntry","fileName":"FluxFlatMap.java","lineNumber":219,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"unsubscribe","fileName":"FluxFlatMap.java","lineNumber":1083,"nativeMethod":false,"className":"reactor.core.publisher.FlatMapTracker"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxFlatMap.java","lineNumber":360,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"MonoCollectList.java","lineNumber":144,"nativeMethod":false,"className":"reactor.core.publisher.MonoCollectList$MonoCollectListSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainLoop","fileName":"Operators.java","lineNumber":2252,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drain","fileName":"Operators.java","lineNumber":2220,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2032,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMap.java","lineNumber":169,"nativeMethod":false,"className":"reactor.core.publisher.FluxMap$MapSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainLoop","fileName":"Operators.java","lineNumber":2252,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drain","fileName":"Operators.java","lineNumber":2220,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2032,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxTakeUntil.java","lineNumber":146,"nativeMethod":false,"className":"reactor.core.publisher.FluxTakeUntil$TakeUntilPredicateSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"MonoIgnoreElements.java","lineNumber":104,"nativeMethod":false,"className":"reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxConcatArray.java","lineNumber":286,"nativeMethod":false,"className":"reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainLoop","fileName":"Operators.java","lineNumber":2252,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drain","fileName":"Operators.java","lineNumber":2220,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2032,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"terminate","fileName":"Operators.java","lineNumber":1240,"nativeMethod":false,"className":"reactor.core.publisher.Operators"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxFlatMap.java","lineNumber":1022,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapInner"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"unsubscribeEntry","fileName":"FluxFlatMap.java","lineNumber":340,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"unsubscribeEntry","fileName":"FluxFlatMap.java","lineNumber":219,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"unsubscribe","fileName":"FluxFlatMap.java","lineNumber":1083,"nativeMethod":false,"className":"reactor.core.publisher.FlatMapTracker"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxFlatMap.java","lineNumber":360,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"doOnCancel","fileName":"MonoSingle.java","lineNumber":108,"nativeMethod":false,"className":"reactor.core.publisher.MonoSingle$SingleSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2784,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MonoInnerProducerBase"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"terminate","fileName":"Operators.java","lineNumber":1240,"nativeMethod":false,"className":"reactor.core.publisher.Operators"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"MonoFlatMap.java","lineNumber":187,"nativeMethod":false,"className":"reactor.core.publisher.MonoFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxPeekFuseable.java","lineNumber":159,"nativeMethod":false,"className":"reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"doOnCancel","fileName":"MonoSingle.java","lineNumber":108,"nativeMethod":false,"className":"reactor.core.publisher.MonoSingle$SingleSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2784,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MonoInnerProducerBase"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"terminate","fileName":"Operators.java","lineNumber":1240,"nativeMethod":false,"className":"reactor.core.publisher.Operators"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"MonoFlatMap.java","lineNumber":187,"nativeMethod":false,"className":"reactor.core.publisher.MonoFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainLoop","fileName":"Operators.java","lineNumber":2252,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drain","fileName":"Operators.java","lineNumber":2220,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2032,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxRetryWhen.java","lineNumber":163,"nativeMethod":false,"className":"reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"SerializedSubscriber.java","lineNumber":157,"nativeMethod":false,"className":"reactor.core.publisher.SerializedSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainLoop","fileName":"Operators.java","lineNumber":2252,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drain","fileName":"Operators.java","lineNumber":2220,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2032,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"MonoPeekTerminal.java","lineNumber":144,"nativeMethod":false,"className":"reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"terminate","fileName":"Operators.java","lineNumber":1240,"nativeMethod":false,"className":"reactor.core.publisher.Operators"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"MonoFlatMap.java","lineNumber":187,"nativeMethod":false,"className":"reactor.core.publisher.MonoFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMapFuseable.java","lineNumber":176,"nativeMethod":false,"className":"reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"terminate","fileName":"Operators.java","lineNumber":1240,"nativeMethod":false,"className":"reactor.core.publisher.Operators"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"MonoFlatMap.java","lineNumber":272,"nativeMethod":false,"className":"reactor.core.publisher.MonoFlatMap$FlatMapInner"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"MonoFlatMap.java","lineNumber":188,"nativeMethod":false,"className":"reactor.core.publisher.MonoFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"doOnCancel","fileName":"MonoSingle.java","lineNumber":108,"nativeMethod":false,"className":"reactor.core.publisher.MonoSingle$SingleSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2784,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MonoInnerProducerBase"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMap.java","lineNumber":169,"nativeMethod":false,"className":"reactor.core.publisher.FluxMap$MapSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainLoop","fileName":"Operators.java","lineNumber":2252,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drain","fileName":"Operators.java","lineNumber":2220,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2032,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxRetryWhen.java","lineNumber":163,"nativeMethod":false,"className":"reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"SerializedSubscriber.java","lineNumber":157,"nativeMethod":false,"className":"reactor.core.publisher.SerializedSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMap.java","lineNumber":169,"nativeMethod":false,"className":"reactor.core.publisher.FluxMap$MapSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"set","fileName":"Operators.java","lineNumber":1160,"nativeMethod":false,"className":"reactor.core.publisher.Operators"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMergeSequential.java","lineNumber":601,"nativeMethod":false,"className":"reactor.core.publisher.FluxMergeSequential$MergeSequentialInner"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancelAll","fileName":"FluxMergeSequential.java","lineNumber":285,"nativeMethod":false,"className":"reactor.core.publisher.FluxMergeSequential$MergeSequentialMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainAndCancel","fileName":"FluxMergeSequential.java","lineNumber":276,"nativeMethod":false,"className":"reactor.core.publisher.FluxMergeSequential$MergeSequentialMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMergeSequential.java","lineNumber":270,"nativeMethod":false,"className":"reactor.core.publisher.FluxMergeSequential$MergeSequentialMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMap.java","lineNumber":169,"nativeMethod":false,"className":"reactor.core.publisher.FluxMap$MapSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMap.java","lineNumber":169,"nativeMethod":false,"className":"reactor.core.publisher.FluxMap$MapSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainLoop","fileName":"Operators.java","lineNumber":2252,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drain","fileName":"Operators.java","lineNumber":2220,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2032,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"set","fileName":"Operators.java","lineNumber":1160,"nativeMethod":false,"className":"reactor.core.publisher.Operators"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMergeSequential.java","lineNumber":601,"nativeMethod":false,"className":"reactor.core.publisher.FluxMergeSequential$MergeSequentialInner"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancelAll","fileName":"FluxMergeSequential.java","lineNumber":285,"nativeMethod":false,"className":"reactor.core.publisher.FluxMergeSequential$MergeSequentialMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainAndCancel","fileName":"FluxMergeSequential.java","lineNumber":276,"nativeMethod":false,"className":"reactor.core.publisher.FluxMergeSequential$MergeSequentialMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMergeSequential.java","lineNumber":270,"nativeMethod":false,"className":"reactor.core.publisher.FluxMergeSequential$MergeSequentialMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxFilter.java","lineNumber":191,"nativeMethod":false,"className":"reactor.core.publisher.FluxFilter$FilterSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMap.java","lineNumber":169,"nativeMethod":false,"className":"reactor.core.publisher.FluxMap$MapSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxConcatArray.java","lineNumber":286,"nativeMethod":false,"className":"reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMap.java","lineNumber":169,"nativeMethod":false,"className":"reactor.core.publisher.FluxMap$MapSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxSkip.java","lineNumber":126,"nativeMethod":false,"className":"reactor.core.publisher.FluxSkip$SkipSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMap.java","lineNumber":169,"nativeMethod":false,"className":"reactor.core.publisher.FluxMap$MapSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMap.java","lineNumber":169,"nativeMethod":false,"className":"reactor.core.publisher.FluxMap$MapSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainLoop","fileName":"Operators.java","lineNumber":2252,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drain","fileName":"Operators.java","lineNumber":2220,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2032,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMap.java","lineNumber":169,"nativeMethod":false,"className":"reactor.core.publisher.FluxMap$MapSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"terminate","fileName":"Operators.java","lineNumber":1240,"nativeMethod":false,"className":"reactor.core.publisher.Operators"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxFlatMap.java","lineNumber":1022,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapInner"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"unsubscribeEntry","fileName":"FluxFlatMap.java","lineNumber":340,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"unsubscribeEntry","fileName":"FluxFlatMap.java","lineNumber":219,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"unsubscribe","fileName":"FluxFlatMap.java","lineNumber":1083,"nativeMethod":false,"className":"reactor.core.publisher.FlatMapTracker"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxFlatMap.java","lineNumber":360,"nativeMethod":false,"className":"reactor.core.publisher.FluxFlatMap$FlatMapMain"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drainLoop","fileName":"Operators.java","lineNumber":2252,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"drain","fileName":"Operators.java","lineNumber":2220,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"Operators.java","lineNumber":2032,"nativeMethod":false,"className":"reactor.core.publisher.Operators$MultiSubscriptionSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxRetryWhen.java","lineNumber":163,"nativeMethod":false,"className":"reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"SerializedSubscriber.java","lineNumber":157,"nativeMethod":false,"className":"reactor.core.publisher.SerializedSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxMap.java","lineNumber":169,"nativeMethod":false,"className":"reactor.core.publisher.FluxMap$MapSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxPeek.java","lineNumber":153,"nativeMethod":false,"className":"reactor.core.publisher.FluxPeek$PeekSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"FluxDoOnEach.java","lineNumber":113,"nativeMethod":false,"className":"reactor.core.publisher.FluxDoOnEach$DoOnEachSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"terminate","fileName":"Operators.java","lineNumber":1240,"nativeMethod":false,"className":"reactor.core.publisher.Operators"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"cancel","fileName":"StrictSubscriber.java","lineNumber":155,"nativeMethod":false,"className":"reactor.core.publisher.StrictSubscriber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"$anonfun$fsm$19","fileName":"StreamSubscriber.scala","lineNumber":196,"nativeMethod":false,"className":"fs2.interop.reactivestreams.StreamSubscriber$"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"nextState","fileName":"StreamSubscriber.scala","lineNumber":215,"nativeMethod":false,"className":"fs2.interop.reactivestreams.StreamSubscriber$$anon$1"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"$anonfun$onFinalize$1","fileName":"StreamSubscriber.scala","lineNumber":221,"nativeMethod":false,"className":"fs2.interop.reactivestreams.StreamSubscriber$$anon$1"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"apply","fileName":"JFunction0$mcV$sp.scala","lineNumber":18,"nativeMethod":false,"className":"scala.runtime.java8.JFunction0$mcV$sp"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"runLoop","fileName":"IOFiber.scala","lineNumber":283,"nativeMethod":false,"className":"cats.effect.IOFiber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"asyncContinueSuccessfulR","fileName":"IOFiber.scala","lineNumber":1338,"nativeMethod":false,"className":"cats.effect.IOFiber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"run","fileName":"IOFiber.scala","lineNumber":140,"nativeMethod":false,"className":"cats.effect.IOFiber"},{"classLoaderName":"app","moduleName":null,"moduleVersion":null,"methodName":"run","fileName":"WorkerThread.scala","lineNumber":549,"nativeMethod":false,"className":"cats.effect.unsafe.WorkerThread"}],"message":null,"suppressed":[],"localizedMessage":null}}: com.azure.core.exception.AzureException
at com.azure.cosmos.implementation.directconnectivity.rntbd.RntbdReporter.doReportIssue(RntbdReporter.java:66)
at com.azure.cosmos.implementation.directconnectivity.rntbd.RntbdReporter.reportIssue(RntbdReporter.java:43)
at com.azure.cosmos.implementation.directconnectivity.RntbdTransportClient.lambda$invokeStoreAsync$2(RntbdTransportClient.java:266)
at reactor.core.publisher.Mono.lambda$onErrorMap$31(Mono.java:3776)
at reactor.core.publisher.FluxOnErrorResume$ResumeSubscriber.onError(FluxOnErrorResume.java:94)
at reactor.core.publisher.MonoCompletionStage.lambda$subscribe$0(MonoCompletionStage.java:89)
at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
at java.base/java.util.concurrent.CompletableFuture.uniWhenCompleteStage(CompletableFuture.java:883)
at java.base/java.util.concurrent.CompletableFuture.whenComplete(CompletableFuture.java:2321)
at java.base/java.util.concurrent.CompletableFuture.whenComplete(CompletableFuture.java:143)
at reactor.core.publisher.MonoCompletionStage.subscribe(MonoCompletionStage.java:67)
at reactor.core.publisher.Mono.subscribe(Mono.java:4455)
at reactor.core.publisher.Mono.subscribeWith(Mono.java:4570)
at reactor.core.publisher.Mono.subscribe(Mono.java:4422)
at reactor.core.publisher.Mono.subscribe(Mono.java:4358)
at reactor.core.publisher.Mono.subscribe(Mono.java:4330)
at com.azure.cosmos.implementation.directconnectivity.RntbdTransportClient.lambda$invokeStoreAsync$5(RntbdTransportClient.java:329)
at reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.runFinally(FluxDoFinally.java:146)
at reactor.core.publisher.FluxDoFinally$DoFinallySubscriber.cancel(FluxDoFinally.java:135)
at reactor.core.publisher.FluxContextWrite$ContextWriteSubscriber.cancel(FluxContextWrite.java:141)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.cancel(FluxFlatMap.java:359)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drainLoop(Operators.java:2252)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drain(Operators.java:2220)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.cancel(Operators.java:2032)
at reactor.core.publisher.Operators.terminate(Operators.java:1240)
at reactor.core.publisher.FluxFlatMap$FlatMapInner.cancel(FluxFlatMap.java:1022)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.unsubscribeEntry(FluxFlatMap.java:340)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.unsubscribeEntry(FluxFlatMap.java:219)
at reactor.core.publisher.FlatMapTracker.unsubscribe(FluxFlatMap.java:1083)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.cancel(FluxFlatMap.java:360)
at reactor.core.publisher.MonoCollectList$MonoCollectListSubscriber.cancel(MonoCollectList.java:144)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drainLoop(Operators.java:2252)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drain(Operators.java:2220)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.cancel(Operators.java:2032)
at reactor.core.publisher.FluxMap$MapSubscriber.cancel(FluxMap.java:169)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drainLoop(Operators.java:2252)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drain(Operators.java:2220)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.cancel(Operators.java:2032)
at reactor.core.publisher.FluxTakeUntil$TakeUntilPredicateSubscriber.cancel(FluxTakeUntil.java:146)
at reactor.core.publisher.MonoIgnoreElements$IgnoreElementsSubscriber.cancel(MonoIgnoreElements.java:104)
at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.cancel(FluxConcatArray.java:286)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drainLoop(Operators.java:2252)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drain(Operators.java:2220)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.cancel(Operators.java:2032)
at reactor.core.publisher.Operators.terminate(Operators.java:1240)
at reactor.core.publisher.FluxFlatMap$FlatMapInner.cancel(FluxFlatMap.java:1022)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.unsubscribeEntry(FluxFlatMap.java:340)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.unsubscribeEntry(FluxFlatMap.java:219)
at reactor.core.publisher.FlatMapTracker.unsubscribe(FluxFlatMap.java:1083)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.cancel(FluxFlatMap.java:360)
at reactor.core.publisher.MonoSingle$SingleSubscriber.doOnCancel(MonoSingle.java:108)
at reactor.core.publisher.Operators$MonoInnerProducerBase.cancel(Operators.java:2784)
at reactor.core.publisher.Operators.terminate(Operators.java:1240)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.cancel(MonoFlatMap.java:187)
at reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.cancel(FluxPeekFuseable.java:159)
at reactor.core.publisher.MonoSingle$SingleSubscriber.doOnCancel(MonoSingle.java:108)
at reactor.core.publisher.Operators$MonoInnerProducerBase.cancel(Operators.java:2784)
at reactor.core.publisher.Operators.terminate(Operators.java:1240)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.cancel(MonoFlatMap.java:187)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drainLoop(Operators.java:2252)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drain(Operators.java:2220)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.cancel(Operators.java:2032)
at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.cancel(FluxRetryWhen.java:163)
at reactor.core.publisher.SerializedSubscriber.cancel(SerializedSubscriber.java:157)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drainLoop(Operators.java:2252)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drain(Operators.java:2220)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.cancel(Operators.java:2032)
at reactor.core.publisher.MonoPeekTerminal$MonoTerminalPeekSubscriber.cancel(MonoPeekTerminal.java:144)
at reactor.core.publisher.Operators.terminate(Operators.java:1240)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.cancel(MonoFlatMap.java:187)
at reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.cancel(FluxMapFuseable.java:176)
at reactor.core.publisher.Operators.terminate(Operators.java:1240)
at reactor.core.publisher.MonoFlatMap$FlatMapInner.cancel(MonoFlatMap.java:272)
at reactor.core.publisher.MonoFlatMap$FlatMapMain.cancel(MonoFlatMap.java:188)
at reactor.core.publisher.MonoSingle$SingleSubscriber.doOnCancel(MonoSingle.java:108)
at reactor.core.publisher.Operators$MonoInnerProducerBase.cancel(Operators.java:2784)
at reactor.core.publisher.FluxMap$MapSubscriber.cancel(FluxMap.java:169)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drainLoop(Operators.java:2252)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drain(Operators.java:2220)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.cancel(Operators.java:2032)
at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.cancel(FluxRetryWhen.java:163)
at reactor.core.publisher.SerializedSubscriber.cancel(SerializedSubscriber.java:157)
at reactor.core.publisher.FluxMap$MapSubscriber.cancel(FluxMap.java:169)
at reactor.core.publisher.Operators.set(Operators.java:1160)
at reactor.core.publisher.FluxMergeSequential$MergeSequentialInner.cancel(FluxMergeSequential.java:601)
at reactor.core.publisher.FluxMergeSequential$MergeSequentialMain.cancelAll(FluxMergeSequential.java:285)
at reactor.core.publisher.FluxMergeSequential$MergeSequentialMain.drainAndCancel(FluxMergeSequential.java:276)
at reactor.core.publisher.FluxMergeSequential$MergeSequentialMain.cancel(FluxMergeSequential.java:270)
at reactor.core.publisher.FluxMap$MapSubscriber.cancel(FluxMap.java:169)
at reactor.core.publisher.FluxMap$MapSubscriber.cancel(FluxMap.java:169)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drainLoop(Operators.java:2252)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drain(Operators.java:2220)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.cancel(Operators.java:2032)
at reactor.core.publisher.Operators.set(Operators.java:1160)
at reactor.core.publisher.FluxMergeSequential$MergeSequentialInner.cancel(FluxMergeSequential.java:601)
at reactor.core.publisher.FluxMergeSequential$MergeSequentialMain.cancelAll(FluxMergeSequential.java:285)
at reactor.core.publisher.FluxMergeSequential$MergeSequentialMain.drainAndCancel(FluxMergeSequential.java:276)
at reactor.core.publisher.FluxMergeSequential$MergeSequentialMain.cancel(FluxMergeSequential.java:270)
at reactor.core.publisher.FluxFilter$FilterSubscriber.cancel(FluxFilter.java:191)
at reactor.core.publisher.FluxMap$MapSubscriber.cancel(FluxMap.java:169)
at reactor.core.publisher.FluxConcatArray$ConcatArraySubscriber.cancel(FluxConcatArray.java:286)
at reactor.core.publisher.FluxMap$MapSubscriber.cancel(FluxMap.java:169)
at reactor.core.publisher.FluxSkip$SkipSubscriber.cancel(FluxSkip.java:126)
at reactor.core.publisher.FluxMap$MapSubscriber.cancel(FluxMap.java:169)
at reactor.core.publisher.FluxMap$MapSubscriber.cancel(FluxMap.java:169)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drainLoop(Operators.java:2252)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drain(Operators.java:2220)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.cancel(Operators.java:2032)
at reactor.core.publisher.FluxMap$MapSubscriber.cancel(FluxMap.java:169)
at reactor.core.publisher.Operators.terminate(Operators.java:1240)
at reactor.core.publisher.FluxFlatMap$FlatMapInner.cancel(FluxFlatMap.java:1022)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.unsubscribeEntry(FluxFlatMap.java:340)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.unsubscribeEntry(FluxFlatMap.java:219)
at reactor.core.publisher.FlatMapTracker.unsubscribe(FluxFlatMap.java:1083)
at reactor.core.publisher.FluxFlatMap$FlatMapMain.cancel(FluxFlatMap.java:360)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drainLoop(Operators.java:2252)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.drain(Operators.java:2220)
at reactor.core.publisher.Operators$MultiSubscriptionSubscriber.cancel(Operators.java:2032)
at reactor.core.publisher.FluxRetryWhen$RetryWhenMainSubscriber.cancel(FluxRetryWhen.java:163)
at reactor.core.publisher.SerializedSubscriber.cancel(SerializedSubscriber.java:157)
at reactor.core.publisher.FluxMap$MapSubscriber.cancel(FluxMap.java:169)
at reactor.core.publisher.FluxPeek$PeekSubscriber.cancel(FluxPeek.java:153)
at reactor.core.publisher.FluxDoOnEach$DoOnEachSubscriber.cancel(FluxDoOnEach.java:113)
at reactor.core.publisher.Operators.terminate(Operators.java:1240)
at reactor.core.publisher.StrictSubscriber.cancel(StrictSubscriber.java:155)
at fs2.interop.reactivestreams.StreamSubscriber$.$anonfun$fsm$19(StreamSubscriber.scala:196)
at fs2.interop.reactivestreams.StreamSubscriber$$anon$1.nextState(StreamSubscriber.scala:215)
at fs2.interop.reactivestreams.StreamSubscriber$$anon$1.$anonfun$onFinalize$1(StreamSubscriber.scala:221)
at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.scala:18)
at cats.effect.IOFiber.runLoop(IOFiber.scala:283)
at cats.effect.IOFiber.asyncContinueSuccessfulR(IOFiber.scala:1338)
at cats.effect.IOFiber.run(IOFiber.scala:140)
at cats.effect.unsafe.WorkerThread.run(WorkerThread.scala:549)
]
To Reproduce
Steps to reproduce the behavior: Unknown. This behavior appears when upgrading from 4.36.0 to 4.37.1. I also see this behavior with 4.38.0.
Code Snippet
Add the code snippet that causes the issue.
Expected behavior
A clear and concise description of what you expected to happen.
Screenshots
If applicable, add screenshots to help explain your problem.
Setup (please complete the following information):
Information Checklist
Kindly make sure that you have added all the following information above and checkoff the required fields otherwise we will treat the issuer as an incomplete report