[Red Hat JIRA] (ISPN-12572) OverlayLocalConfigurationStorage.persistConfigurations should be synchronized
by Tristan Tarrant (Jira)
[ https://issues.redhat.com/browse/ISPN-12572?page=com.atlassian.jira.plugi... ]
Tristan Tarrant updated ISPN-12572:
-----------------------------------
Fix Version/s: 12.0.0.Final
(was: 12.0.0.CR1)
> OverlayLocalConfigurationStorage.persistConfigurations should be synchronized
> -----------------------------------------------------------------------------
>
> Key: ISPN-12572
> URL: https://issues.redhat.com/browse/ISPN-12572
> Project: Infinispan
> Issue Type: Bug
> Components: Core
> Affects Versions: 12.0.0.Dev07
> Reporter: Dan Berindei
> Assignee: Dan Berindei
> Priority: Major
> Fix For: 12.0.0.Final
>
>
> {{OverlayLocalConfigurationStorage.persistConfigurations}} uses {{FileChannel.lock()}} to serialize access to the {{caches.xml}} or {{templates.xml}} files.
> But {{FileChannel.lock()}} assumes that a single thread in the JVM is locking the file, otherwise it throws an exception:
> {noformat}
> 2020-12-10 08:33:50,422 FATAL (main) [org.infinispan.SERVER] ISPN080028: Infinispan Server failed to start java.util.concurrent.ExecutionException: org.infinispan.manager.EmbeddedCacheManagerStartupException: org.infinispan.commons.CacheConfigurationException: Error starting component org.infinispan.globalstate.GlobalConfigurationManager
> at java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:395)
> at java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1999)
> at org.infinispan.server.Bootstrap.runInternal(Bootstrap.java:158)
> at org.infinispan.server.tool.Main.run(Main.java:98)
> at org.infinispan.server.Bootstrap.main(Bootstrap.java:46)
> at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.base/java.lang.reflect.Method.invoke(Method.java:566)
> at org.infinispan.server.loader.Loader.run(Loader.java:103)
> at org.infinispan.server.loader.Loader.main(Loader.java:48)
> Caused by: org.infinispan.manager.EmbeddedCacheManagerStartupException: org.infinispan.commons.CacheConfigurationException: Error starting component org.infinispan.globalstate.GlobalConfigurationManager
> at org.infinispan.manager.DefaultCacheManager.internalStart(DefaultCacheManager.java:751)
> at org.infinispan.manager.DefaultCacheManager.start(DefaultCacheManager.java:717)
> at org.infinispan.server.SecurityActions.lambda$startCacheManager$1(SecurityActions.java:67)
> at org.infinispan.security.Security.doPrivileged(Security.java:45)
> at org.infinispan.server.SecurityActions.doPrivileged(SecurityActions.java:39)
> at org.infinispan.server.SecurityActions.startCacheManager(SecurityActions.java:70)
> at org.infinispan.server.Server.run(Server.java:346)
> ... 9 more
> Caused by: org.infinispan.commons.CacheConfigurationException: Error starting component org.infinispan.globalstate.GlobalConfigurationManager
> at org.infinispan.factories.impl.BasicComponentRegistryImpl.startWrapper(BasicComponentRegistryImpl.java:572)
> at org.infinispan.factories.impl.BasicComponentRegistryImpl.access$700(BasicComponentRegistryImpl.java:30)
> at org.infinispan.factories.impl.BasicComponentRegistryImpl$ComponentWrapper.running(BasicComponentRegistryImpl.java:787)
> at org.infinispan.factories.AbstractComponentRegistry.internalStart(AbstractComponentRegistry.java:341)
> at org.infinispan.factories.AbstractComponentRegistry.start(AbstractComponentRegistry.java:237)
> at org.infinispan.manager.DefaultCacheManager.internalStart(DefaultCacheManager.java:746)
> ... 15 more
> Caused by: java.util.concurrent.CompletionException: org.infinispan.commons.CacheConfigurationException: ISPN000502: Error while persisting global configuration state
> at org.infinispan.util.concurrent.CompletionStages.join(CompletionStages.java:81)
> at org.infinispan.globalstate.impl.GlobalConfigurationManagerImpl.lambda$start$0(GlobalConfigurationManagerImpl.java:115)
> at org.infinispan.cache.impl.EncoderCache.lambda$forEach$7(EncoderCache.java:762)
> at java.base/java.util.concurrent.ConcurrentMap.forEach(ConcurrentMap.java:122)
> at org.infinispan.cache.impl.AbstractDelegatingCache.forEach(AbstractDelegatingCache.java:479)
> at org.infinispan.cache.impl.AbstractDelegatingCache.forEach(AbstractDelegatingCache.java:479)
> at org.infinispan.cache.impl.AbstractDelegatingCache.forEach(AbstractDelegatingCache.java:479)
> at org.infinispan.cache.impl.EncoderCache.forEach(EncoderCache.java:759)
> at org.infinispan.globalstate.impl.GlobalConfigurationManagerImpl.start(GlobalConfigurationManagerImpl.java:106)
> at org.infinispan.globalstate.impl.CorePackageImpl$2.start(CorePackageImpl.java:59)
> at org.infinispan.globalstate.impl.CorePackageImpl$2.start(CorePackageImpl.java:48)
> at org.infinispan.factories.impl.BasicComponentRegistryImpl.invokeStart(BasicComponentRegistryImpl.java:604)
> at org.infinispan.factories.impl.BasicComponentRegistryImpl.doStartWrapper(BasicComponentRegistryImpl.java:595)
> at org.infinispan.factories.impl.BasicComponentRegistryImpl.startWrapper(BasicComponentRegistryImpl.java:564)
> ... 20 more
> Caused by: org.infinispan.commons.CacheConfigurationException: ISPN000502: Error while persisting global configuration state
> at org.infinispan.globalstate.impl.OverlayLocalConfigurationStorage.persistConfigurations(OverlayLocalConfigurationStorage.java:156)
> at org.infinispan.globalstate.impl.OverlayLocalConfigurationStorage.storeCaches(OverlayLocalConfigurationStorage.java:130)
> at org.infinispan.globalstate.impl.OverlayLocalConfigurationStorage.lambda$createCache$2(OverlayLocalConfigurationStorage.java:79)
> at java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:642)
> at java.base/java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:478)
> at org.jboss.threads.ContextClassLoaderSavingRunnable.run(ContextClassLoaderSavingRunnable.java:35)
> at org.jboss.threads.EnhancedQueueExecutor.safeRun(EnhancedQueueExecutor.java:1982)
> at org.jboss.threads.EnhancedQueueExecutor$ThreadBody.doRunTask(EnhancedQueueExecutor.java:1486)
> at org.jboss.threads.EnhancedQueueExecutor$ThreadBody.run(EnhancedQueueExecutor.java:1377)
> at java.base/java.lang.Thread.run(Thread.java:834)
> Caused by: org.infinispan.commons.CacheConfigurationException: ISPN000508: Cannot rename file /home/infinispan/workspace/Infinispan_PR-8921/jcache/tck-runner-remote/target/infinispan-server/server/data/caches9096240479751965790.tmp to /home/infinispan/workspace/Infinispan_PR-8921/jcache/tck-runner-remote/target/infinispan-server/server/data/caches.xml
> at org.infinispan.globalstate.impl.OverlayLocalConfigurationStorage.persistConfigurations(OverlayLocalConfigurationStorage.java:153)
> ... 9 more
> Caused by: java.nio.channels.OverlappingFileLockException
> at java.base/sun.nio.ch.FileLockTable.checkList(FileLockTable.java:229)
> at java.base/sun.nio.ch.FileLockTable.add(FileLockTable.java:123)
> at java.base/sun.nio.ch.FileChannelImpl.lock(FileChannelImpl.java:1109)
> at java.base/java.nio.channels.FileChannel.lock(FileChannel.java:1063)
> at org.infinispan.commons.util.Util.renameTempFile(Util.java:1087)
> at org.infinispan.globalstate.impl.OverlayLocalConfigurationStorage.persistConfigurations(OverlayLocalConfigurationStorage.java:151)
> ... 9 more
> {noformat}
--
This message was sent by Atlassian Jira
(v7.13.8#713008)
5 years, 3 months
[Red Hat JIRA] (ISPN-12575) Refactor XSiteStateTransferManager
by Tristan Tarrant (Jira)
[ https://issues.redhat.com/browse/ISPN-12575?page=com.atlassian.jira.plugi... ]
Tristan Tarrant updated ISPN-12575:
-----------------------------------
Status: Resolved (was: Pull Request Sent)
Fix Version/s: 12.0.0.CR1
Resolution: Done
> Refactor XSiteStateTransferManager
> ----------------------------------
>
> Key: ISPN-12575
> URL: https://issues.redhat.com/browse/ISPN-12575
> Project: Infinispan
> Issue Type: Sub-task
> Components: Cross-Site Replication
> Reporter: Pedro Ruivo
> Assignee: Pedro Ruivo
> Priority: Major
> Fix For: 12.0.0.CR1
>
>
> Refactor {{XSiteStateTransferManagerImpl}} to make it easier to implement the conflict resolution.
> Bonus: make the following methods non-blocking: state transfer ack ({{notifyStatePushFinished}}) & topology update ({{onTopologyUpdated}}). Other methods are invoked from use input (JMX).
--
This message was sent by Atlassian Jira
(v7.13.8#713008)
5 years, 3 months
[Red Hat JIRA] (ISPN-12595) Exception for embedded cache Iteration if partition handling is configured
by Wolf-Dieter Fink (Jira)
Wolf-Dieter Fink created ISPN-12595:
---------------------------------------
Summary: Exception for embedded cache Iteration if partition handling is configured
Key: ISPN-12595
URL: https://issues.redhat.com/browse/ISPN-12595
Project: Infinispan
Issue Type: Bug
Components: Core, Partition Handling
Affects Versions: 12.0.0.Dev07
Reporter: Wolf-Dieter Fink
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, 3 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)
5 years, 3 months
[Red Hat JIRA] (ISPN-12594) Exception for embedded cache Iteration if partition handling is configured
by Wolf-Dieter Fink (Jira)
Wolf-Dieter Fink created ISPN-12594:
---------------------------------------
Summary: 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
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, 3 months
[Red Hat JIRA] (ISPN-12388) Integration with Knative Eventing
by Tristan Tarrant (Jira)
[ https://issues.redhat.com/browse/ISPN-12388?page=com.atlassian.jira.plugi... ]
Tristan Tarrant updated ISPN-12388:
-----------------------------------
Status: Resolved (was: Pull Request Sent)
Fix Version/s: 12.0.0.CR1
(was: 12.0.0.Final)
Resolution: Done
> Integration with Knative Eventing
> ---------------------------------
>
> Key: ISPN-12388
> URL: https://issues.redhat.com/browse/ISPN-12388
> Project: Infinispan
> Issue Type: Feature Request
> Components: Core
> Reporter: Dan Berindei
> Assignee: Dan Berindei
> Priority: Major
> Fix For: 12.0.0.CR1
>
>
> Produce different types of cloud-events to integrate with KNative eventing:
> * ISPN-11767 Emit Cloud Events for security audit events
> * ISPN-11768 Emit Cloud Events for cache level notifications
> * ISPN-11769 Emit Cloud Events for cache manager notifications
--
This message was sent by Atlassian Jira
(v7.13.8#713008)
5 years, 3 months
[Red Hat JIRA] (ISPN-12584) Protobuf serialization among peers in for library mode with spring starter
by Dan Berindei (Jira)
[ https://issues.redhat.com/browse/ISPN-12584?page=com.atlassian.jira.plugi... ]
Dan Berindei reassigned ISPN-12584:
-----------------------------------
Assignee: Dan Berindei
> Protobuf serialization among peers in for library mode with spring starter
> --------------------------------------------------------------------------
>
> Key: ISPN-12584
> URL: https://issues.redhat.com/browse/ISPN-12584
> Project: Infinispan
> Issue Type: Bug
> Components: Marshalling
> Affects Versions: 12.0.0.Dev07, 11.0.8.Final
> Reporter: Ramon Gordillo Gutierrez
> Assignee: Dan Berindei
> Priority: Major
> Fix For: 12.0.0.Final
>
>
> With 11.0.8, I get the following exception when doing a put in a replicated-cache:
> {noformat}
> 2020-12-18 07:21:43.232 WARN 1 --- [98f-md4d4-51498] org.infinispan.PERSISTENCE : ISPN000559: Cannot marshall 'class com.redhat.Customer'
> java.lang.IllegalArgumentException: No marshaller registered for Java type com.redhat.Customer{noformat}
> Same code is working right on a local-cache
> I have tried also 12.0.0.Dev7 (with 11.0.6 spring starter), and the exception is similar but slightly different:
> {noformat}
> 2020-12-18 08:07:48.956 WARN 1 --- [nio-8080-exec-1] org.infinispan.PERSISTENCE: ISPN000559: Cannot marshall 'class org.infinispan.spring.common.provider.NullValue'
> java.lang.IllegalArgumentException: No marshaller registered for Java type org.infinispan.spring.common.provider.
> {noformat}
--
This message was sent by Atlassian Jira
(v7.13.8#713008)
5 years, 3 months