Uploaded image for project: 'Red Hat Data Grid'
  1. Red Hat Data Grid
  2. JDG-4262

Exception for embedded cache Iteration if partition handling is configured

    XMLWordPrintable

    Details

    • Target Release:
    • Fix Build:
      CR2
    • Steps to Reproduce:
      Hide

      Use the attached reproducer

      Show
      Use the attached reproducer
    • Workaround Description:
      Hide

      Use distributedBatchSize and set the cache size

      cache.keySet().stream().distributedBatchSize(cache.size() - 2)
       
       

      Show
      Use distributedBatchSize and set the cache size cache.keySet().stream().distributedBatchSize(cache.size() - 2)    

      Description

      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

        Attachments

          Issue Links

            Activity

              People

              Assignee:
              dan.berindei Dan Berindei
              Reporter:
              wdfink Wolf-Dieter Fink
              Votes:
              0 Vote for this issue
              Watchers:
              5 Start watching this issue

                Dates

                Created:
                Updated:
                Resolved: