[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)
3 years, 4 months
[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)
3 years, 4 months
[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)
3 years, 4 months
[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)
3 years, 4 months
[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)
3 years, 4 months
[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)
3 years, 4 months
[Red Hat JIRA] (ISPN-12597) Disable JGroups error JGRP000006 stacktrace when configuring xsite on OCP and AWS LB
by Dmitry Volodin (Jira)
[ https://issues.redhat.com/browse/ISPN-12597?page=com.atlassian.jira.plugi... ]
Dmitry Volodin updated ISPN-12597:
----------------------------------
Summary: Disable JGroups error JGRP000006 stacktrace when configuring xsite on OCP and AWS LB (was: Disable JGroups error JGRP000006 stacktarce when configuring xsite on OCP and AWS LB)
> Disable JGroups error JGRP000006 stacktrace when configuring xsite on OCP and AWS LB
> ------------------------------------------------------------------------------------
>
> Key: ISPN-12597
> URL: https://issues.redhat.com/browse/ISPN-12597
> Project: Infinispan
> Issue Type: Enhancement
> Components: Cross-Site Replication, OpenShift, Operator
> Affects Versions: 11.0.7.Final
> Reporter: Dmitry Volodin
> Assignee: Pedro Ruivo
> Priority: Minor
>
> When configuring Cross-Site on OCP with operator and LoadBalancer on AWS (probably, will occurs on Azure and others cloud platforms) there are a large number of stack traces places inside Pod logs
>
> {code:java}
> 07:51:13,524 WARN (TcpServer.Acceptor[7900]-2,relay-global,_example-infinispan-1-11053:site1) [org.jgroups.protocols.TCP] JGRP000006: failed accepting connection from peer Socket[addr=/10.131.0.1,port=11781,localport=7900]: java.io.EOFException java.io.EOFException at java.base/java.io.DataInputStream.readFully(DataInputStream.java:202) at org.jgroups.blocks.cs.TcpConnection.readPeerAddress(TcpConnection.java:247) at org.jgroups.blocks.cs.TcpConnection.<init>(TcpConnection.java:53) at org.jgroups.blocks.cs.TcpServer$Acceptor.handleAccept(TcpServer.java:126) at org.jgroups.blocks.cs.TcpServer$Acceptor.run(TcpServer.java:111) at java.base/java.lang.Thread.run(Thread.java:834){code}
> The reason of this logs that's AWS/OCP pings LoadBalancer with probe each time with interval. No the same errors while internal (Service) cross-site configuration was made.
> It would be nice to have an option to disable this kind of traces probably for LB configuration only, as customers confusing this traces as a problem
>
--
This message was sent by Atlassian Jira
(v7.13.8#713008)
3 years, 4 months
[Red Hat JIRA] (ISPN-12598) Hot Rod java client retries too many times
by Dan Berindei (Jira)
[ https://issues.redhat.com/browse/ISPN-12598?page=com.atlassian.jira.plugi... ]
Dan Berindei updated ISPN-12598:
--------------------------------
Description:
The Java Hot Rod client has a {{maxRetries}} configuration option which tells it how many times to retry an operation after a failure (default: 10).
When the number of retries is exceeded, the client does not fail immediately: instead, it tries to switch to another site, and tries {{maxRetries}} times on the new site as well. The client doesn't keep track of the clusters it switched off of, so it seems possible to go in an infinite loop, switching from one site to the next.
If the client cannot switch to another site (e.g. because it was configured with a single site), it logs a debug message (`Cluster might have completely shut down, try resetting transport layer and topology id`) and tries the current site again for {{maxRetries}} times. So the actual number of retries with a single site is {{2 * maxRetries}} (or 1, if {{maxRetries == 0}}).
Maybe automatic site switching is a good idea in some cases, but I'm not convinced it should be the default behaviour. At the very least, site switching should be decided at the remote cache manager level, when the client fails to open a new connection to any server in the current site, and not based on the number of retries done for any particular operation.
was:
The Java Hot Rod client has a {{maxRetries}} configuration option which tells it how many times to retry an operation after a failure (default: 10).
When the number of retries is exceeded, the client does not fail immediately: instead, it tries to switch to another site, and tries {{maxRetries}} times on the new site as well. The client doesn't keep track of the clusters it switched off of, so it seems possible to go in an infinite loop, switching from one site to the next.
If the client cannot switch to another site (e.g. because it was configured with a single site), it logs a debug message (`Cluster might have completely shut down, try resetting transport layer and topology id`) and tries the current site again for {{maxRetries}} times. So the actual number of retries with a single site is {{2 * maxRetries}}.
Maybe automatic site switching is a good idea in some cases, but I'm not convinced it should be the default behaviour. At the very least, site switching should be decided at the remote cache manager level, when the client fails to open a new connection to any server in the current site, and not based on the number of retries done for any particular operation.
> Hot Rod java client retries too many times
> ------------------------------------------
>
> Key: ISPN-12598
> URL: https://issues.redhat.com/browse/ISPN-12598
> Project: Infinispan
> Issue Type: Bug
> Components: Hot Rod
> Affects Versions: 12.0.0.CR1
> Reporter: Dan Berindei
> Assignee: Dan Berindei
> Priority: Major
> Fix For: 12.0.0.Final
>
>
> The Java Hot Rod client has a {{maxRetries}} configuration option which tells it how many times to retry an operation after a failure (default: 10).
> When the number of retries is exceeded, the client does not fail immediately: instead, it tries to switch to another site, and tries {{maxRetries}} times on the new site as well. The client doesn't keep track of the clusters it switched off of, so it seems possible to go in an infinite loop, switching from one site to the next.
> If the client cannot switch to another site (e.g. because it was configured with a single site), it logs a debug message (`Cluster might have completely shut down, try resetting transport layer and topology id`) and tries the current site again for {{maxRetries}} times. So the actual number of retries with a single site is {{2 * maxRetries}} (or 1, if {{maxRetries == 0}}).
> Maybe automatic site switching is a good idea in some cases, but I'm not convinced it should be the default behaviour. At the very least, site switching should be decided at the remote cache manager level, when the client fails to open a new connection to any server in the current site, and not based on the number of retries done for any particular operation.
--
This message was sent by Atlassian Jira
(v7.13.8#713008)
3 years, 4 months