Exception for embedded cache Iteration if partition handling is configured -------------------------------------------------------------------------- Key: ISPN-12594 URL: https://issues.redhat.com/browse/ISPN-12594 Project: Infinispan Issue Type: Bug Components: Core, Partition Handling Affects Versions: 12.0.0.Dev07 Reporter: Wolf-Dieter Fink Priority: Critical Attachments: IterationTest.zip No matter whether streams are used or not the Iteration with values() keySet() entrySet() throws the following Exception org.infinispan.commons.CacheException: io.reactivex.rxjava3.exceptions.MissingBackpressureException: Could not emit value due to lack of requests at org.infinispan.commons.util.Util.rewrapAsCacheException(Util.java:686) at org.infinispan.commons.reactive.RxJavaInterop.lambda$static$2(RxJavaInterop.java:47) at io.reactivex.rxjava3.internal.operators.flowable.FlowableOnErrorNext$OnErrorNextSubscriber.onError(FlowableOnErrorNext.java:94) at io.reactivex.rxjava3.internal.operators.flowable.FlowableDoOnEach$DoOnEachSubscriber.onError(FlowableDoOnEach.java:111) at io.reactivex.rxjava3.processors.PublishProcessor$PublishSubscription.onNext(PublishProcessor.java:367) at io.reactivex.rxjava3.processors.PublishProcessor.onNext(PublishProcessor.java:242) at io.reactivex.rxjava3.processors.SerializedProcessor.onNext(SerializedProcessor.java:103) at io.reactivex.rxjava3.internal.operators.flowable.FlowableRepeatUntil$RepeatSubscriber.onNext(FlowableRepeatUntil.java:67) at io.reactivex.rxjava3.internal.operators.flowable.FlowableDoOnLifecycle$SubscriptionLambdaSubscriber.onNext(FlowableDoOnLifecycle.java:79) at io.reactivex.rxjava3.processors.UnicastProcessor.drainRegular(UnicastProcessor.java:309) at io.reactivex.rxjava3.processors.UnicastProcessor.drain(UnicastProcessor.java:384) at io.reactivex.rxjava3.processors.UnicastProcessor.subscribeActual(UnicastProcessor.java:486) at io.reactivex.rxjava3.core.Flowable.subscribe(Flowable.java:15750) at io.reactivex.rxjava3.internal.operators.flowable.FlowableDoOnLifecycle.subscribeActual(FlowableDoOnLifecycle.java:38) at io.reactivex.rxjava3.core.Flowable.subscribe(Flowable.java:15750) at io.reactivex.rxjava3.core.Flowable.subscribe(Flowable.java:15696) at io.reactivex.rxjava3.internal.operators.flowable.FlowableScalarXMap$ScalarXMapFlowable.subscribeActual(FlowableScalarXMap.java:160) at io.reactivex.rxjava3.core.Flowable.subscribe(Flowable.java:15750) at io.reactivex.rxjava3.core.Flowable.subscribe(Flowable.java:15696) at io.reactivex.rxjava3.internal.operators.flowable.FlowableScalarXMap$ScalarXMapFlowable.subscribeActual(FlowableScalarXMap.java:160) at io.reactivex.rxjava3.core.Flowable.subscribe(Flowable.java:15750) at io.reactivex.rxjava3.core.Flowable.subscribe(Flowable.java:15696) at io.reactivex.rxjava3.internal.operators.flowable.FlowableRepeatUntil$RepeatSubscriber.subscribeNext(FlowableRepeatUntil.java:109) at io.reactivex.rxjava3.internal.operators.flowable.FlowableRepeatUntil.subscribeActual(FlowableRepeatUntil.java:38) at io.reactivex.rxjava3.core.Flowable.subscribe(Flowable.java:15750) at io.reactivex.rxjava3.core.Flowable.subscribe(Flowable.java:15696) at org.infinispan.reactive.publisher.impl.ClusterPublisherManagerImpl$SubscriberHandler.start(ClusterPublisherManagerImpl.java:973) at org.infinispan.reactive.publisher.impl.ClusterPublisherManagerImpl$AbstractSegmentAwarePublisher.subscribe(ClusterPublisherManagerImpl.java:1170) at org.infinispan.reactive.publisher.impl.PartitionAwareClusterPublisherManager.lambda$registerPublisher$2(PartitionAwareClusterPublisherManager.java:144) at org.infinispan.reactive.publisher.impl.SegmentCompletionPublisher.subscribe(SegmentCompletionPublisher.java:34) at io.reactivex.rxjava3.internal.operators.flowable.FlowableFromPublisher.subscribeActual(FlowableFromPublisher.java:29) at io.reactivex.rxjava3.core.Flowable.subscribe(Flowable.java:15750) at io.reactivex.rxjava3.internal.operators.flowable.FlowableOnErrorNext.subscribeActual(FlowableOnErrorNext.java:39) at io.reactivex.rxjava3.core.Flowable.subscribe(Flowable.java:15750) at io.reactivex.rxjava3.internal.operators.flowable.BlockingFlowableIterable.iterator(BlockingFlowableIterable.java:42) at org.infinispan.commons.util.Closeables.iterator(Closeables.java:238) at org.infinispan.util.Closeables.iterator(Closeables.java:26) at org.infinispan.stream.impl.DistributedCacheStream.iterator(DistributedCacheStream.java:376) at org.infinispan.commons.util.Closeables.iterator(Closeables.java:73) at org.infinispan.interceptors.distribution.DistributionBulkInterceptor$BackingEntrySet.iterator(DistributionBulkInterceptor.java:80) at org.infinispan.interceptors.distribution.DistributionBulkInterceptor$BackingEntrySet.iterator(DistributionBulkInterceptor.java:67) at org.infinispan.util.WriteableCacheCollectionMapper.iterator(WriteableCacheCollectionMapper.java:60) at org.infinispan.wfink.clustered.ClusteredIterationStandalone.loop2(ClusteredIterationStandalone.java:83) at org.infinispan.wfink.clustered.ClusteredIterationStandalone.main(ClusteredIterationStandalone.java:136) Caused by: io.reactivex.rxjava3.exceptions.MissingBackpressureException: Could not emit value due to lack of requests