[JBoss JIRA] (ISPN-2575) KeyTransformer registration is required on all nodes of the cluster, in case of custom keys
by Mircea Markus (JIRA)
[ https://issues.jboss.org/browse/ISPN-2575?page=com.atlassian.jira.plugin.... ]
Mircea Markus updated ISPN-2575:
--------------------------------
Assignee: Adrian Nistor (was: Sanne Grinovero)
> KeyTransformer registration is required on all nodes of the cluster, in case of custom keys
> -------------------------------------------------------------------------------------------
>
> Key: ISPN-2575
> URL: https://issues.jboss.org/browse/ISPN-2575
> Project: Infinispan
> Issue Type: Enhancement
> Components: Querying
> Affects Versions: 5.2.0.Beta5
> Reporter: Anna Manukyan
> Assignee: Adrian Nistor
> Attachments: ClusteredCacheTest.java
>
>
> The case is the following:
> I have a clustered cache on which I want to perform a search. I'm doing the following:
> I'm initializing SearchManager on node1, I'm registering a custom key transformer for my key using the created searchmanager, but then when I'm trying to put data into the cache on node1 (which is in REPL_SYNC mode with cache on node2), I'm getting the exception:
> java.lang.IllegalArgumentException: Indexing only works with entries keyed on Strings, primitives and classes that have the @Transformable annotation - you passed in a class org.infinispan.query.test.CustomKey3. Alternatively, see org.infinispan.query.SearchManager#registerKeyTransformer
> When I'm initializing the SearchManager using node2 cache and register the keyTransformer on it as well, then everything works perfectly, even though I am not using the second created SearchManager.
> The test which reproduces the issue is attached to the jira. Please see the test case: testSearchKeyTransformer()
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
3 months, 3 weeks
[Red Hat JIRA] (ISPN-12592) Improve error message when XML element is removed
by Katia Aresti (Jira)
[ https://issues.redhat.com/browse/ISPN-12592?page=com.atlassian.jira.plugi... ]
Katia Aresti updated ISPN-12592:
--------------------------------
Status: Resolved (was: Pull Request Sent)
Resolution: Done
> Improve error message when XML element is removed
> -------------------------------------------------
>
> Key: ISPN-12592
> URL: https://issues.redhat.com/browse/ISPN-12592
> Project: Infinispan
> Issue Type: Enhancement
> Components: Configuration, Core
> Affects Versions: 12.0.0.Dev07
> Reporter: Dan Berindei
> Assignee: Dan Berindei
> Priority: Major
> Fix For: 12.0.0.Final
>
>
> When an element is removed from the XML configuration schema, configurations using the old XML namespace trigger a warning that the element is deprecated, including the name of the replacement element.
> Configurations files with no namespace declarations are assumed to be using the latest schema and don't trigger the warning, instead they trigger a generic `Unexpected element 'X' encountered` exception.
> Assuming the latest schema is the right thing to do, but we need to improve the error message for upgraders.
--
This message was sent by Atlassian Jira
(v7.13.8#713008)
5 years, 1 month
[Red Hat JIRA] (ISPN-12594) Exception for embedded cache Iteration if partition handling is configured
by Dan Berindei (Jira)
[ https://issues.redhat.com/browse/ISPN-12594?page=com.atlassian.jira.plugi... ]
Dan Berindei updated ISPN-12594:
--------------------------------
Status: Pull Request Sent (was: Open)
Git Pull Request: https://github.com/infinispan/infinispan/pull/8954
> 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
--
This message was sent by Atlassian Jira
(v7.13.8#713008)
5 years, 1 month
[Red Hat JIRA] (ISPN-12594) Exception for embedded cache Iteration if partition handling is configured
by Dan Berindei (Jira)
[ https://issues.redhat.com/browse/ISPN-12594?page=com.atlassian.jira.plugi... ]
Dan Berindei updated ISPN-12594:
--------------------------------
Status: Open (was: New)
> 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
--
This message was sent by Atlassian Jira
(v7.13.8#713008)
5 years, 1 month
[Red Hat JIRA] (ISPN-12594) Exception for embedded cache Iteration if partition handling is configured
by Wolf-Dieter Fink (Jira)
[ https://issues.redhat.com/browse/ISPN-12594?page=com.atlassian.jira.plugi... ]
Wolf-Dieter Fink updated ISPN-12594:
------------------------------------
Attachment: IterationTest.zip
> 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
--
This message was sent by Atlassian Jira
(v7.13.8#713008)
5 years, 1 month
[Red Hat JIRA] (ISPN-12594) Exception for embedded cache Iteration if partition handling is configured
by Wolf-Dieter Fink (Jira)
[ https://issues.redhat.com/browse/ISPN-12594?page=com.atlassian.jira.plugi... ]
Wolf-Dieter Fink updated ISPN-12594:
------------------------------------
Attachment: (was: IterationTest.zip)
> 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
--
This message was sent by Atlassian Jira
(v7.13.8#713008)
5 years, 1 month
[Red Hat JIRA] (ISPN-12594) Exception for embedded cache Iteration if partition handling is configured
by Dan Berindei (Jira)
[ https://issues.redhat.com/browse/ISPN-12594?page=com.atlassian.jira.plugi... ]
Dan Berindei updated ISPN-12594:
--------------------------------
Workaround Description:
Use distributedBatchSize and set the cache size
cache.keySet().stream().distributedBatchSize(cache.size() - 2)
was:
Use distributedBatchSize and set the cache size
cache.keySet().stream().distributedBatchSize(cache.size())
> 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
--
This message was sent by Atlassian Jira
(v7.13.8#713008)
5 years, 1 month