com.couchbase.client.core.error.UnambiguousTimeoutException: RangeScanCreateRequest, Reason: TIMEOUT {"cancelled":true,"completed":true,"coreId":"0x464acf7e0000000b","idempotent":true,"lastDispatchedTo":"172.23.120.128","reason":"TIMEOUT","requestId":77303,"requestType":"RangeScanCreateRequest","retried":0,"service":{"bucket":"default","collection":"collection-7","opaque":"0x149ad","scope":"scope1","type":"kv","vbucket":0},"timeoutMs":-10000}
|
at com.couchbase.client.core.msg.BaseRequest.cancel(BaseRequest.java:184)
|
at com.couchbase.client.core.msg.Request.cancel(Request.java:71)
|
at com.couchbase.client.core.endpoint.BaseEndpoint.send(BaseEndpoint.java:573)
|
at com.couchbase.client.core.service.PooledService.send(PooledService.java:287)
|
at com.couchbase.client.core.service.KeyValueService.send(KeyValueService.java:29)
|
at com.couchbase.client.core.node.Node.send(Node.java:390)
|
at com.couchbase.client.core.node.KeyValueLocator.couchbaseBucket(KeyValueLocator.java:159)
|
at com.couchbase.client.core.node.KeyValueLocator.dispatch(KeyValueLocator.java:85)
|
at com.couchbase.client.core.Core.send(Core.java:401)
|
at com.couchbase.client.core.Core.send(Core.java:374)
|
at com.couchbase.client.core.kv.RangeScanOrchestrator.lambda$streamForPartition$10(RangeScanOrchestrator.java:201)
|
at reactor.core.publisher.FluxDefer.subscribe(FluxDefer.java:46)
|
at reactor.core.publisher.InternalFluxOperator.subscribe(InternalFluxOperator.java:62)
|
at reactor.core.publisher.FluxRetryWhen.subscribe(FluxRetryWhen.java:77)
|
at reactor.core.publisher.FluxRetryWhen.subscribeOrReturn(FluxRetryWhen.java:83)
|
at reactor.core.publisher.Flux.subscribe(Flux.java:8646)
|
at reactor.core.publisher.FluxConcatIterable$ConcatIterableSubscriber.onComplete(FluxConcatIterable.java:147)
|
at reactor.core.publisher.FluxConcatIterable.subscribe(FluxConcatIterable.java:60)
|
at reactor.core.publisher.InternalFluxOperator.subscribe(InternalFluxOperator.java:62)
|
at reactor.core.publisher.FluxDefer.subscribe(FluxDefer.java:54)
|
at reactor.core.publisher.InternalFluxOperator.subscribe(InternalFluxOperator.java:62)
|