[JBoss JIRA] (ISPN-10371) Refactor ProtocolServer thread pools
by Will Burns (Jira)
Will Burns created ISPN-10371:
---------------------------------
Summary: Refactor ProtocolServer thread pools
Key: ISPN-10371
URL: https://issues.jboss.org/browse/ISPN-10371
Project: Infinispan
Issue Type: Sub-task
Components: Server
Reporter: Will Burns
Fix For: 10.0.0.Final
Today we have protocol servers for REST/Hotrod/Memcached etc. These use their own pools of default sizes of 160 threads. These pools should be completely removed and use the appropriate thread pool from the cache manager itself. We can't really touch the Netty pools, but with the single port luckily this will consolidate the netty thread pool down to 1 for all protocols combined which is good.
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
4 years, 9 months
[JBoss JIRA] (ISPN-10370) Remove compatibility mode
by Gustavo Fernandes (Jira)
Gustavo Fernandes created ISPN-10370:
----------------------------------------
Summary: Remove compatibility mode
Key: ISPN-10370
URL: https://issues.jboss.org/browse/ISPN-10370
Project: Infinispan
Issue Type: Task
Components: Core, Server
Affects Versions: 10.0.0.Beta3
Reporter: Gustavo Fernandes
Assignee: Gustavo Fernandes
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
4 years, 9 months
[JBoss JIRA] (ISPN-10369) InvalidatedNearCacheTest random failures
by Dan Berindei (Jira)
Dan Berindei created ISPN-10369:
-----------------------------------
Summary: InvalidatedNearCacheTest random failures
Key: ISPN-10369
URL: https://issues.jboss.org/browse/ISPN-10369
Project: Infinispan
Issue Type: Bug
Components: Test Suite - Server
Affects Versions: 10.0.0.Beta3
Reporter: Dan Berindei
Assignee: Dan Berindei
Fix For: 10.0.0.Beta4
{{InvalidatedNearCacheTest.testGetNearCacheAfterConnect}} has 2 clients, performing some operations and waiting for the corresponding near cache events on client 1 and then resetting the events on client 2.
This is not correct, because client 2 may not have received the events yet, in which case {{resetEvents()}} doesn't do anything.
{noformat}
18:48:47,813 INFO (testng-InvalidatedNearCacheTest:[]) [TestSuiteProgress] Test succeeded: org.infinispan.client.hotrod.near.InvalidatedNearCacheTest.testGetNearCacheAfterConnect
18:48:47,814 INFO (testng-InvalidatedNearCacheTest:[]) [TestSuiteProgress] Test starting: org.infinispan.client.hotrod.near.InvalidatedNearCacheTest.testGetUpdatesNearCache
18:48:47,821 ERROR (testng-InvalidatedNearCacheTest:[]) [TestSuiteProgress] Test failed: org.infinispan.client.hotrod.near.InvalidatedNearCacheTest.testGetUpdatesNearCache
18:48:47,821 ERROR (testng-InvalidatedNearCacheTest:[]) [TestSuiteProgress] Test failed: org.infinispan.client.hotrod.near.InvalidatedNearCacheTest.testGetUpdatesNearCache
java.lang.AssertionError: [org.infinispan.client.hotrod.near.MockNearCacheService$MockRemoveEvent@514f3f0c, org.infinispan.client.hotrod.near.MockNearCacheService$MockRemoveEvent@76bf7455] expected:<0> but was:<2>
at org.testng.AssertJUnit.fail(AssertJUnit.java:59) ~[testng-6.14.3.jar:?]
at org.testng.AssertJUnit.failNotEquals(AssertJUnit.java:364) ~[testng-6.14.3.jar:?]
at org.testng.AssertJUnit.assertEquals(AssertJUnit.java:80) ~[testng-6.14.3.jar:?]
at org.testng.AssertJUnit.assertEquals(AssertJUnit.java:245) ~[testng-6.14.3.jar:?]
at org.infinispan.client.hotrod.near.AssertsNearCache.expectNoNearEvents(AssertsNearCache.java:123) ~[test-classes/:?]
at org.infinispan.client.hotrod.near.InvalidatedNearCacheTest.testGetUpdatesNearCache(InvalidatedNearCacheTest.java:153) ~[test-classes/:?]
{noformat}
https://ci.infinispan.org/job/Infinispan/job/master/1240/
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
4 years, 9 months
[JBoss JIRA] (ISPN-10368) All thread pools should have a queue
by Dan Berindei (Jira)
[ https://issues.jboss.org/browse/ISPN-10368?page=com.atlassian.jira.plugin... ]
Dan Berindei updated ISPN-10368:
--------------------------------
Status: Open (was: New)
> All thread pools should have a queue
> ------------------------------------
>
> Key: ISPN-10368
> URL: https://issues.jboss.org/browse/ISPN-10368
> Project: Infinispan
> Issue Type: Bug
> Components: Core, Test Suite - Core
> Affects Versions: 10.0.0.Beta3
> Reporter: Dan Berindei
> Assignee: Will Burns
> Priority: Major
> Labels: testsuite_stability
> Fix For: 10.0.0.CR1
>
>
> Random failures in {{DistSyncStoreNotSharedTest}} because the cpu executor ({{ASYNC_OPERATIONS_EXECUTOR}}) rejected a task:
> {noformat}
> java.util.concurrent.CompletionException: java.lang.AssertionError: Thread name is: persistence-thread-DistSyncStoreNotSharedTest-NodeB-p16499-t5
> at org.infinispan.util.concurrent.CompletionStages.join(CompletionStages.java:75)
> at org.infinispan.stream.impl.AbstractCacheStream.performPublisherOperation(AbstractCacheStream.java:290)
> at org.infinispan.stream.impl.DistributedCacheStream.anyMatch(DistributedCacheStream.java:328)
> at org.infinispan.cache.impl.CacheImpl.isEmpty(CacheImpl.java:502)
> at org.infinispan.cache.impl.CacheImpl.isEmpty(CacheImpl.java:498)
> at org.infinispan.cache.impl.AbstractDelegatingCache.isEmpty(AbstractDelegatingCache.java:379)
> at org.infinispan.distribution.DistSyncStoreNotSharedTest.prepareClearTest(DistSyncStoreNotSharedTest.java:348)
> at org.infinispan.distribution.DistSyncStoreNotSharedTest.testClearWithFlag(DistSyncStoreNotSharedTest.java:305)
> at org.infinispan.commons.test.TestNGLongTestsHook.run(TestNGLongTestsHook.java:24)
> at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
> at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
> at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
> at java.base/java.lang.Thread.run(Thread.java:834)
> Caused by: java.lang.AssertionError: Thread name is: persistence-thread-DistSyncStoreNotSharedTest-NodeB-p16499-t5
> at org.infinispan.persistence.manager.PersistenceManagerImpl.publishEntries(PersistenceManagerImpl.java:699)
> at org.infinispan.persistence.manager.PersistenceManagerImpl.publishEntries(PersistenceManagerImpl.java:120)
> at org.infinispan.interceptors.impl.CacheLoaderInterceptor$WrappedEntrySet.getCacheEntryPublisher(CacheLoaderInterceptor.java:726)
> at org.infinispan.interceptors.impl.CacheLoaderInterceptor$WrappedEntrySet.localPublisher(CacheLoaderInterceptor.java:713)
> at org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl.lambda$exactlyOnceSequential$7(LocalPublisherManagerImpl.java:372)
> at org.infinispan.util.rxjava.FlowableFromIntSetFunction$IteratorSubscription.slowPath(FlowableFromIntSetFunction.java:223)
> at org.infinispan.util.rxjava.FlowableFromIntSetFunction$BaseRangeSubscription.request(FlowableFromIntSetFunction.java:127)
> at io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.drainLoop(FlowableFlatMap.java:546)
> at io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.drain(FlowableFlatMap.java:366)
> at io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.onComplete(FlowableFlatMap.java:678)
> at io.reactivex.internal.subscriptions.DeferredScalarSubscription.complete(DeferredScalarSubscription.java:119)
> at io.reactivex.processors.AsyncProcessor.onComplete(AsyncProcessor.java:201)
> at org.infinispan.reactive.RxJavaInterop.lambda$static$5(RxJavaInterop.java:120)
> at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
> at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
> at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
> at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073)
> at io.reactivex.internal.observers.ConsumerSingleObserver.onSuccess(ConsumerSingleObserver.java:62)
> at io.reactivex.internal.operators.flowable.FlowableAnySingle$AnySubscriber.onComplete(FlowableAnySingle.java:109)
> at io.reactivex.internal.operators.flowable.FlowableDoOnEach$DoOnEachSubscriber.onComplete(FlowableDoOnEach.java:135)
> at io.reactivex.internal.operators.flowable.FlowableConcatArray$ConcatArraySubscriber.onComplete(FlowableConcatArray.java:112)
> at io.reactivex.internal.subscribers.BasicFuseableSubscriber.onComplete(BasicFuseableSubscriber.java:120)
> at io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.checkTerminated(FlowableObserveOn.java:215)
> at io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.runAsync(FlowableObserveOn.java:399)
> at io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.run(FlowableObserveOn.java:176)
> at io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker$BooleanRunnable.run(ExecutorScheduler.java:260)
> at io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.run(ExecutorScheduler.java:225)
> at org.infinispan.commons.util.concurrent.CallerRunsRejectOnShutdownPolicy.rejectedExecution(CallerRunsRejectOnShutdownPolicy.java:19)
> at java.base/java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:825)
> at java.base/java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1355)
> at org.infinispan.executors.LazyInitializingExecutorService.execute(LazyInitializingExecutorService.java:138)
> at io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.schedule(ExecutorScheduler.java:143)
> at io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.trySchedule(FlowableObserveOn.java:166)
> at io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.onComplete(FlowableObserveOn.java:135)
> at io.reactivex.internal.operators.flowable.FlowableSubscribeOn$SubscribeOnSubscriber.onComplete(FlowableSubscribeOn.java:108)
> at io.reactivex.internal.operators.flowable.FlowableUsing$UsingSubscriber.onComplete(FlowableUsing.java:148)
> at io.reactivex.internal.subscribers.BasicFuseableSubscriber.onComplete(BasicFuseableSubscriber.java:120)
> at io.reactivex.internal.subscribers.BasicFuseableConditionalSubscriber.onComplete(BasicFuseableConditionalSubscriber.java:119)
> at io.reactivex.internal.subscribers.BasicFuseableConditionalSubscriber.onComplete(BasicFuseableConditionalSubscriber.java:119)
> at io.reactivex.internal.subscriptions.EmptySubscription.complete(EmptySubscription.java:69)
> {noformat}
> https://ci.infinispan.org/job/Infinispan/job/master/1269/
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
4 years, 9 months
[JBoss JIRA] (ISPN-10368) All thread pools should have a queue
by Dan Berindei (Jira)
[ https://issues.jboss.org/browse/ISPN-10368?page=com.atlassian.jira.plugin... ]
Dan Berindei updated ISPN-10368:
--------------------------------
Component/s: Core
Test Suite - Core
Fix Version/s: 10.0.0.CR1
Sprint: DataGrid Sprint #30
Affects Version/s: 10.0.0.Beta3
> All thread pools should have a queue
> ------------------------------------
>
> Key: ISPN-10368
> URL: https://issues.jboss.org/browse/ISPN-10368
> Project: Infinispan
> Issue Type: Bug
> Components: Core, Test Suite - Core
> Affects Versions: 10.0.0.Beta3
> Reporter: Dan Berindei
> Assignee: Will Burns
> Priority: Major
> Labels: testsuite_stability
> Fix For: 10.0.0.CR1
>
>
> Random failures in {{DistSyncStoreNotSharedTest}} because the cpu executor ({{ASYNC_OPERATIONS_EXECUTOR}}) rejected a task:
> {noformat}
> java.util.concurrent.CompletionException: java.lang.AssertionError: Thread name is: persistence-thread-DistSyncStoreNotSharedTest-NodeB-p16499-t5
> at org.infinispan.util.concurrent.CompletionStages.join(CompletionStages.java:75)
> at org.infinispan.stream.impl.AbstractCacheStream.performPublisherOperation(AbstractCacheStream.java:290)
> at org.infinispan.stream.impl.DistributedCacheStream.anyMatch(DistributedCacheStream.java:328)
> at org.infinispan.cache.impl.CacheImpl.isEmpty(CacheImpl.java:502)
> at org.infinispan.cache.impl.CacheImpl.isEmpty(CacheImpl.java:498)
> at org.infinispan.cache.impl.AbstractDelegatingCache.isEmpty(AbstractDelegatingCache.java:379)
> at org.infinispan.distribution.DistSyncStoreNotSharedTest.prepareClearTest(DistSyncStoreNotSharedTest.java:348)
> at org.infinispan.distribution.DistSyncStoreNotSharedTest.testClearWithFlag(DistSyncStoreNotSharedTest.java:305)
> at org.infinispan.commons.test.TestNGLongTestsHook.run(TestNGLongTestsHook.java:24)
> at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
> at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
> at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
> at java.base/java.lang.Thread.run(Thread.java:834)
> Caused by: java.lang.AssertionError: Thread name is: persistence-thread-DistSyncStoreNotSharedTest-NodeB-p16499-t5
> at org.infinispan.persistence.manager.PersistenceManagerImpl.publishEntries(PersistenceManagerImpl.java:699)
> at org.infinispan.persistence.manager.PersistenceManagerImpl.publishEntries(PersistenceManagerImpl.java:120)
> at org.infinispan.interceptors.impl.CacheLoaderInterceptor$WrappedEntrySet.getCacheEntryPublisher(CacheLoaderInterceptor.java:726)
> at org.infinispan.interceptors.impl.CacheLoaderInterceptor$WrappedEntrySet.localPublisher(CacheLoaderInterceptor.java:713)
> at org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl.lambda$exactlyOnceSequential$7(LocalPublisherManagerImpl.java:372)
> at org.infinispan.util.rxjava.FlowableFromIntSetFunction$IteratorSubscription.slowPath(FlowableFromIntSetFunction.java:223)
> at org.infinispan.util.rxjava.FlowableFromIntSetFunction$BaseRangeSubscription.request(FlowableFromIntSetFunction.java:127)
> at io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.drainLoop(FlowableFlatMap.java:546)
> at io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.drain(FlowableFlatMap.java:366)
> at io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.onComplete(FlowableFlatMap.java:678)
> at io.reactivex.internal.subscriptions.DeferredScalarSubscription.complete(DeferredScalarSubscription.java:119)
> at io.reactivex.processors.AsyncProcessor.onComplete(AsyncProcessor.java:201)
> at org.infinispan.reactive.RxJavaInterop.lambda$static$5(RxJavaInterop.java:120)
> at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
> at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
> at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
> at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073)
> at io.reactivex.internal.observers.ConsumerSingleObserver.onSuccess(ConsumerSingleObserver.java:62)
> at io.reactivex.internal.operators.flowable.FlowableAnySingle$AnySubscriber.onComplete(FlowableAnySingle.java:109)
> at io.reactivex.internal.operators.flowable.FlowableDoOnEach$DoOnEachSubscriber.onComplete(FlowableDoOnEach.java:135)
> at io.reactivex.internal.operators.flowable.FlowableConcatArray$ConcatArraySubscriber.onComplete(FlowableConcatArray.java:112)
> at io.reactivex.internal.subscribers.BasicFuseableSubscriber.onComplete(BasicFuseableSubscriber.java:120)
> at io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.checkTerminated(FlowableObserveOn.java:215)
> at io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.runAsync(FlowableObserveOn.java:399)
> at io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.run(FlowableObserveOn.java:176)
> at io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker$BooleanRunnable.run(ExecutorScheduler.java:260)
> at io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.run(ExecutorScheduler.java:225)
> at org.infinispan.commons.util.concurrent.CallerRunsRejectOnShutdownPolicy.rejectedExecution(CallerRunsRejectOnShutdownPolicy.java:19)
> at java.base/java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:825)
> at java.base/java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1355)
> at org.infinispan.executors.LazyInitializingExecutorService.execute(LazyInitializingExecutorService.java:138)
> at io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.schedule(ExecutorScheduler.java:143)
> at io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.trySchedule(FlowableObserveOn.java:166)
> at io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.onComplete(FlowableObserveOn.java:135)
> at io.reactivex.internal.operators.flowable.FlowableSubscribeOn$SubscribeOnSubscriber.onComplete(FlowableSubscribeOn.java:108)
> at io.reactivex.internal.operators.flowable.FlowableUsing$UsingSubscriber.onComplete(FlowableUsing.java:148)
> at io.reactivex.internal.subscribers.BasicFuseableSubscriber.onComplete(BasicFuseableSubscriber.java:120)
> at io.reactivex.internal.subscribers.BasicFuseableConditionalSubscriber.onComplete(BasicFuseableConditionalSubscriber.java:119)
> at io.reactivex.internal.subscribers.BasicFuseableConditionalSubscriber.onComplete(BasicFuseableConditionalSubscriber.java:119)
> at io.reactivex.internal.subscriptions.EmptySubscription.complete(EmptySubscription.java:69)
> {noformat}
> https://ci.infinispan.org/job/Infinispan/job/master/1269/
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
4 years, 9 months
[JBoss JIRA] (ISPN-10368) All thread pools should have a queue
by Dan Berindei (Jira)
[ https://issues.jboss.org/browse/ISPN-10368?page=com.atlassian.jira.plugin... ]
Dan Berindei updated ISPN-10368:
--------------------------------
Description:
Random failures in {{DistSyncStoreNotSharedTest}} because the cpu executor ({{ASYNC_OPERATIONS_EXECUTOR}}) rejected a task:
{noformat}
java.util.concurrent.CompletionException: java.lang.AssertionError: Thread name is: persistence-thread-DistSyncStoreNotSharedTest-NodeB-p16499-t5
at org.infinispan.util.concurrent.CompletionStages.join(CompletionStages.java:75)
at org.infinispan.stream.impl.AbstractCacheStream.performPublisherOperation(AbstractCacheStream.java:290)
at org.infinispan.stream.impl.DistributedCacheStream.anyMatch(DistributedCacheStream.java:328)
at org.infinispan.cache.impl.CacheImpl.isEmpty(CacheImpl.java:502)
at org.infinispan.cache.impl.CacheImpl.isEmpty(CacheImpl.java:498)
at org.infinispan.cache.impl.AbstractDelegatingCache.isEmpty(AbstractDelegatingCache.java:379)
at org.infinispan.distribution.DistSyncStoreNotSharedTest.prepareClearTest(DistSyncStoreNotSharedTest.java:348)
at org.infinispan.distribution.DistSyncStoreNotSharedTest.testClearWithFlag(DistSyncStoreNotSharedTest.java:305)
at org.infinispan.commons.test.TestNGLongTestsHook.run(TestNGLongTestsHook.java:24)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
Caused by: java.lang.AssertionError: Thread name is: persistence-thread-DistSyncStoreNotSharedTest-NodeB-p16499-t5
at org.infinispan.persistence.manager.PersistenceManagerImpl.publishEntries(PersistenceManagerImpl.java:699)
at org.infinispan.persistence.manager.PersistenceManagerImpl.publishEntries(PersistenceManagerImpl.java:120)
at org.infinispan.interceptors.impl.CacheLoaderInterceptor$WrappedEntrySet.getCacheEntryPublisher(CacheLoaderInterceptor.java:726)
at org.infinispan.interceptors.impl.CacheLoaderInterceptor$WrappedEntrySet.localPublisher(CacheLoaderInterceptor.java:713)
at org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl.lambda$exactlyOnceSequential$7(LocalPublisherManagerImpl.java:372)
at org.infinispan.util.rxjava.FlowableFromIntSetFunction$IteratorSubscription.slowPath(FlowableFromIntSetFunction.java:223)
at org.infinispan.util.rxjava.FlowableFromIntSetFunction$BaseRangeSubscription.request(FlowableFromIntSetFunction.java:127)
at io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.drainLoop(FlowableFlatMap.java:546)
at io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.drain(FlowableFlatMap.java:366)
at io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.onComplete(FlowableFlatMap.java:678)
at io.reactivex.internal.subscriptions.DeferredScalarSubscription.complete(DeferredScalarSubscription.java:119)
at io.reactivex.processors.AsyncProcessor.onComplete(AsyncProcessor.java:201)
at org.infinispan.reactive.RxJavaInterop.lambda$static$5(RxJavaInterop.java:120)
at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073)
at io.reactivex.internal.observers.ConsumerSingleObserver.onSuccess(ConsumerSingleObserver.java:62)
at io.reactivex.internal.operators.flowable.FlowableAnySingle$AnySubscriber.onComplete(FlowableAnySingle.java:109)
at io.reactivex.internal.operators.flowable.FlowableDoOnEach$DoOnEachSubscriber.onComplete(FlowableDoOnEach.java:135)
at io.reactivex.internal.operators.flowable.FlowableConcatArray$ConcatArraySubscriber.onComplete(FlowableConcatArray.java:112)
at io.reactivex.internal.subscribers.BasicFuseableSubscriber.onComplete(BasicFuseableSubscriber.java:120)
at io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.checkTerminated(FlowableObserveOn.java:215)
at io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.runAsync(FlowableObserveOn.java:399)
at io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.run(FlowableObserveOn.java:176)
at io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker$BooleanRunnable.run(ExecutorScheduler.java:260)
at io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.run(ExecutorScheduler.java:225)
at org.infinispan.commons.util.concurrent.CallerRunsRejectOnShutdownPolicy.rejectedExecution(CallerRunsRejectOnShutdownPolicy.java:19)
at java.base/java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:825)
at java.base/java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1355)
at org.infinispan.executors.LazyInitializingExecutorService.execute(LazyInitializingExecutorService.java:138)
at io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.schedule(ExecutorScheduler.java:143)
at io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.trySchedule(FlowableObserveOn.java:166)
at io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.onComplete(FlowableObserveOn.java:135)
at io.reactivex.internal.operators.flowable.FlowableSubscribeOn$SubscribeOnSubscriber.onComplete(FlowableSubscribeOn.java:108)
at io.reactivex.internal.operators.flowable.FlowableUsing$UsingSubscriber.onComplete(FlowableUsing.java:148)
at io.reactivex.internal.subscribers.BasicFuseableSubscriber.onComplete(BasicFuseableSubscriber.java:120)
at io.reactivex.internal.subscribers.BasicFuseableConditionalSubscriber.onComplete(BasicFuseableConditionalSubscriber.java:119)
at io.reactivex.internal.subscribers.BasicFuseableConditionalSubscriber.onComplete(BasicFuseableConditionalSubscriber.java:119)
at io.reactivex.internal.subscriptions.EmptySubscription.complete(EmptySubscription.java:69)
{noformat}
https://ci.infinispan.org/job/Infinispan/job/master/1269/
was:
Random failures in {{DistSyncStoreNotSharedTest}] because the cpu executor ({{ASYNC_OPERATIONS_EXECUTOR}}) rejected a task:
{noformat}
java.util.concurrent.CompletionException: java.lang.AssertionError: Thread name is: persistence-thread-DistSyncStoreNotSharedTest-NodeB-p16499-t5
at org.infinispan.util.concurrent.CompletionStages.join(CompletionStages.java:75)
at org.infinispan.stream.impl.AbstractCacheStream.performPublisherOperation(AbstractCacheStream.java:290)
at org.infinispan.stream.impl.DistributedCacheStream.anyMatch(DistributedCacheStream.java:328)
at org.infinispan.cache.impl.CacheImpl.isEmpty(CacheImpl.java:502)
at org.infinispan.cache.impl.CacheImpl.isEmpty(CacheImpl.java:498)
at org.infinispan.cache.impl.AbstractDelegatingCache.isEmpty(AbstractDelegatingCache.java:379)
at org.infinispan.distribution.DistSyncStoreNotSharedTest.prepareClearTest(DistSyncStoreNotSharedTest.java:348)
at org.infinispan.distribution.DistSyncStoreNotSharedTest.testClearWithFlag(DistSyncStoreNotSharedTest.java:305)
at org.infinispan.commons.test.TestNGLongTestsHook.run(TestNGLongTestsHook.java:24)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
Caused by: java.lang.AssertionError: Thread name is: persistence-thread-DistSyncStoreNotSharedTest-NodeB-p16499-t5
at org.infinispan.persistence.manager.PersistenceManagerImpl.publishEntries(PersistenceManagerImpl.java:699)
at org.infinispan.persistence.manager.PersistenceManagerImpl.publishEntries(PersistenceManagerImpl.java:120)
at org.infinispan.interceptors.impl.CacheLoaderInterceptor$WrappedEntrySet.getCacheEntryPublisher(CacheLoaderInterceptor.java:726)
at org.infinispan.interceptors.impl.CacheLoaderInterceptor$WrappedEntrySet.localPublisher(CacheLoaderInterceptor.java:713)
at org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl.lambda$exactlyOnceSequential$7(LocalPublisherManagerImpl.java:372)
at org.infinispan.util.rxjava.FlowableFromIntSetFunction$IteratorSubscription.slowPath(FlowableFromIntSetFunction.java:223)
at org.infinispan.util.rxjava.FlowableFromIntSetFunction$BaseRangeSubscription.request(FlowableFromIntSetFunction.java:127)
at io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.drainLoop(FlowableFlatMap.java:546)
at io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.drain(FlowableFlatMap.java:366)
at io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.onComplete(FlowableFlatMap.java:678)
at io.reactivex.internal.subscriptions.DeferredScalarSubscription.complete(DeferredScalarSubscription.java:119)
at io.reactivex.processors.AsyncProcessor.onComplete(AsyncProcessor.java:201)
at org.infinispan.reactive.RxJavaInterop.lambda$static$5(RxJavaInterop.java:120)
at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073)
at io.reactivex.internal.observers.ConsumerSingleObserver.onSuccess(ConsumerSingleObserver.java:62)
at io.reactivex.internal.operators.flowable.FlowableAnySingle$AnySubscriber.onComplete(FlowableAnySingle.java:109)
at io.reactivex.internal.operators.flowable.FlowableDoOnEach$DoOnEachSubscriber.onComplete(FlowableDoOnEach.java:135)
at io.reactivex.internal.operators.flowable.FlowableConcatArray$ConcatArraySubscriber.onComplete(FlowableConcatArray.java:112)
at io.reactivex.internal.subscribers.BasicFuseableSubscriber.onComplete(BasicFuseableSubscriber.java:120)
at io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.checkTerminated(FlowableObserveOn.java:215)
at io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.runAsync(FlowableObserveOn.java:399)
at io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.run(FlowableObserveOn.java:176)
at io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker$BooleanRunnable.run(ExecutorScheduler.java:260)
at io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.run(ExecutorScheduler.java:225)
at org.infinispan.commons.util.concurrent.CallerRunsRejectOnShutdownPolicy.rejectedExecution(CallerRunsRejectOnShutdownPolicy.java:19)
at java.base/java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:825)
at java.base/java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1355)
at org.infinispan.executors.LazyInitializingExecutorService.execute(LazyInitializingExecutorService.java:138)
at io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.schedule(ExecutorScheduler.java:143)
at io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.trySchedule(FlowableObserveOn.java:166)
at io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.onComplete(FlowableObserveOn.java:135)
at io.reactivex.internal.operators.flowable.FlowableSubscribeOn$SubscribeOnSubscriber.onComplete(FlowableSubscribeOn.java:108)
at io.reactivex.internal.operators.flowable.FlowableUsing$UsingSubscriber.onComplete(FlowableUsing.java:148)
at io.reactivex.internal.subscribers.BasicFuseableSubscriber.onComplete(BasicFuseableSubscriber.java:120)
at io.reactivex.internal.subscribers.BasicFuseableConditionalSubscriber.onComplete(BasicFuseableConditionalSubscriber.java:119)
at io.reactivex.internal.subscribers.BasicFuseableConditionalSubscriber.onComplete(BasicFuseableConditionalSubscriber.java:119)
at io.reactivex.internal.subscriptions.EmptySubscription.complete(EmptySubscription.java:69)
{noformat}
https://ci.infinispan.org/job/Infinispan/job/master/1269/
> All thread pools should have a queue
> ------------------------------------
>
> Key: ISPN-10368
> URL: https://issues.jboss.org/browse/ISPN-10368
> Project: Infinispan
> Issue Type: Bug
> Affects Versions: 10.0.0.Beta3
> Reporter: Dan Berindei
> Assignee: Will Burns
> Priority: Major
> Labels: testsuite_stability
> Fix For: 10.0.0.CR1
>
>
> Random failures in {{DistSyncStoreNotSharedTest}} because the cpu executor ({{ASYNC_OPERATIONS_EXECUTOR}}) rejected a task:
> {noformat}
> java.util.concurrent.CompletionException: java.lang.AssertionError: Thread name is: persistence-thread-DistSyncStoreNotSharedTest-NodeB-p16499-t5
> at org.infinispan.util.concurrent.CompletionStages.join(CompletionStages.java:75)
> at org.infinispan.stream.impl.AbstractCacheStream.performPublisherOperation(AbstractCacheStream.java:290)
> at org.infinispan.stream.impl.DistributedCacheStream.anyMatch(DistributedCacheStream.java:328)
> at org.infinispan.cache.impl.CacheImpl.isEmpty(CacheImpl.java:502)
> at org.infinispan.cache.impl.CacheImpl.isEmpty(CacheImpl.java:498)
> at org.infinispan.cache.impl.AbstractDelegatingCache.isEmpty(AbstractDelegatingCache.java:379)
> at org.infinispan.distribution.DistSyncStoreNotSharedTest.prepareClearTest(DistSyncStoreNotSharedTest.java:348)
> at org.infinispan.distribution.DistSyncStoreNotSharedTest.testClearWithFlag(DistSyncStoreNotSharedTest.java:305)
> at org.infinispan.commons.test.TestNGLongTestsHook.run(TestNGLongTestsHook.java:24)
> at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
> at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
> at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
> at java.base/java.lang.Thread.run(Thread.java:834)
> Caused by: java.lang.AssertionError: Thread name is: persistence-thread-DistSyncStoreNotSharedTest-NodeB-p16499-t5
> at org.infinispan.persistence.manager.PersistenceManagerImpl.publishEntries(PersistenceManagerImpl.java:699)
> at org.infinispan.persistence.manager.PersistenceManagerImpl.publishEntries(PersistenceManagerImpl.java:120)
> at org.infinispan.interceptors.impl.CacheLoaderInterceptor$WrappedEntrySet.getCacheEntryPublisher(CacheLoaderInterceptor.java:726)
> at org.infinispan.interceptors.impl.CacheLoaderInterceptor$WrappedEntrySet.localPublisher(CacheLoaderInterceptor.java:713)
> at org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl.lambda$exactlyOnceSequential$7(LocalPublisherManagerImpl.java:372)
> at org.infinispan.util.rxjava.FlowableFromIntSetFunction$IteratorSubscription.slowPath(FlowableFromIntSetFunction.java:223)
> at org.infinispan.util.rxjava.FlowableFromIntSetFunction$BaseRangeSubscription.request(FlowableFromIntSetFunction.java:127)
> at io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.drainLoop(FlowableFlatMap.java:546)
> at io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.drain(FlowableFlatMap.java:366)
> at io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.onComplete(FlowableFlatMap.java:678)
> at io.reactivex.internal.subscriptions.DeferredScalarSubscription.complete(DeferredScalarSubscription.java:119)
> at io.reactivex.processors.AsyncProcessor.onComplete(AsyncProcessor.java:201)
> at org.infinispan.reactive.RxJavaInterop.lambda$static$5(RxJavaInterop.java:120)
> at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
> at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
> at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
> at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073)
> at io.reactivex.internal.observers.ConsumerSingleObserver.onSuccess(ConsumerSingleObserver.java:62)
> at io.reactivex.internal.operators.flowable.FlowableAnySingle$AnySubscriber.onComplete(FlowableAnySingle.java:109)
> at io.reactivex.internal.operators.flowable.FlowableDoOnEach$DoOnEachSubscriber.onComplete(FlowableDoOnEach.java:135)
> at io.reactivex.internal.operators.flowable.FlowableConcatArray$ConcatArraySubscriber.onComplete(FlowableConcatArray.java:112)
> at io.reactivex.internal.subscribers.BasicFuseableSubscriber.onComplete(BasicFuseableSubscriber.java:120)
> at io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.checkTerminated(FlowableObserveOn.java:215)
> at io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.runAsync(FlowableObserveOn.java:399)
> at io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.run(FlowableObserveOn.java:176)
> at io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker$BooleanRunnable.run(ExecutorScheduler.java:260)
> at io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.run(ExecutorScheduler.java:225)
> at org.infinispan.commons.util.concurrent.CallerRunsRejectOnShutdownPolicy.rejectedExecution(CallerRunsRejectOnShutdownPolicy.java:19)
> at java.base/java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:825)
> at java.base/java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1355)
> at org.infinispan.executors.LazyInitializingExecutorService.execute(LazyInitializingExecutorService.java:138)
> at io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.schedule(ExecutorScheduler.java:143)
> at io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.trySchedule(FlowableObserveOn.java:166)
> at io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.onComplete(FlowableObserveOn.java:135)
> at io.reactivex.internal.operators.flowable.FlowableSubscribeOn$SubscribeOnSubscriber.onComplete(FlowableSubscribeOn.java:108)
> at io.reactivex.internal.operators.flowable.FlowableUsing$UsingSubscriber.onComplete(FlowableUsing.java:148)
> at io.reactivex.internal.subscribers.BasicFuseableSubscriber.onComplete(BasicFuseableSubscriber.java:120)
> at io.reactivex.internal.subscribers.BasicFuseableConditionalSubscriber.onComplete(BasicFuseableConditionalSubscriber.java:119)
> at io.reactivex.internal.subscribers.BasicFuseableConditionalSubscriber.onComplete(BasicFuseableConditionalSubscriber.java:119)
> at io.reactivex.internal.subscriptions.EmptySubscription.complete(EmptySubscription.java:69)
> {noformat}
> https://ci.infinispan.org/job/Infinispan/job/master/1269/
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
4 years, 9 months
[JBoss JIRA] (ISPN-10368) All thread pools should have a queue
by Dan Berindei (Jira)
Dan Berindei created ISPN-10368:
-----------------------------------
Summary: All thread pools should have a queue
Key: ISPN-10368
URL: https://issues.jboss.org/browse/ISPN-10368
Project: Infinispan
Issue Type: Bug
Reporter: Dan Berindei
Assignee: Will Burns
Random failures in {{DistSyncStoreNotSharedTest}] because the cpu executor ({{ASYNC_OPERATIONS_EXECUTOR}}) rejected a task:
{noformat}
java.util.concurrent.CompletionException: java.lang.AssertionError: Thread name is: persistence-thread-DistSyncStoreNotSharedTest-NodeB-p16499-t5
at org.infinispan.util.concurrent.CompletionStages.join(CompletionStages.java:75)
at org.infinispan.stream.impl.AbstractCacheStream.performPublisherOperation(AbstractCacheStream.java:290)
at org.infinispan.stream.impl.DistributedCacheStream.anyMatch(DistributedCacheStream.java:328)
at org.infinispan.cache.impl.CacheImpl.isEmpty(CacheImpl.java:502)
at org.infinispan.cache.impl.CacheImpl.isEmpty(CacheImpl.java:498)
at org.infinispan.cache.impl.AbstractDelegatingCache.isEmpty(AbstractDelegatingCache.java:379)
at org.infinispan.distribution.DistSyncStoreNotSharedTest.prepareClearTest(DistSyncStoreNotSharedTest.java:348)
at org.infinispan.distribution.DistSyncStoreNotSharedTest.testClearWithFlag(DistSyncStoreNotSharedTest.java:305)
at org.infinispan.commons.test.TestNGLongTestsHook.run(TestNGLongTestsHook.java:24)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
at java.base/java.lang.Thread.run(Thread.java:834)
Caused by: java.lang.AssertionError: Thread name is: persistence-thread-DistSyncStoreNotSharedTest-NodeB-p16499-t5
at org.infinispan.persistence.manager.PersistenceManagerImpl.publishEntries(PersistenceManagerImpl.java:699)
at org.infinispan.persistence.manager.PersistenceManagerImpl.publishEntries(PersistenceManagerImpl.java:120)
at org.infinispan.interceptors.impl.CacheLoaderInterceptor$WrappedEntrySet.getCacheEntryPublisher(CacheLoaderInterceptor.java:726)
at org.infinispan.interceptors.impl.CacheLoaderInterceptor$WrappedEntrySet.localPublisher(CacheLoaderInterceptor.java:713)
at org.infinispan.reactive.publisher.impl.LocalPublisherManagerImpl.lambda$exactlyOnceSequential$7(LocalPublisherManagerImpl.java:372)
at org.infinispan.util.rxjava.FlowableFromIntSetFunction$IteratorSubscription.slowPath(FlowableFromIntSetFunction.java:223)
at org.infinispan.util.rxjava.FlowableFromIntSetFunction$BaseRangeSubscription.request(FlowableFromIntSetFunction.java:127)
at io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.drainLoop(FlowableFlatMap.java:546)
at io.reactivex.internal.operators.flowable.FlowableFlatMap$MergeSubscriber.drain(FlowableFlatMap.java:366)
at io.reactivex.internal.operators.flowable.FlowableFlatMap$InnerSubscriber.onComplete(FlowableFlatMap.java:678)
at io.reactivex.internal.subscriptions.DeferredScalarSubscription.complete(DeferredScalarSubscription.java:119)
at io.reactivex.processors.AsyncProcessor.onComplete(AsyncProcessor.java:201)
at org.infinispan.reactive.RxJavaInterop.lambda$static$5(RxJavaInterop.java:120)
at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073)
at io.reactivex.internal.observers.ConsumerSingleObserver.onSuccess(ConsumerSingleObserver.java:62)
at io.reactivex.internal.operators.flowable.FlowableAnySingle$AnySubscriber.onComplete(FlowableAnySingle.java:109)
at io.reactivex.internal.operators.flowable.FlowableDoOnEach$DoOnEachSubscriber.onComplete(FlowableDoOnEach.java:135)
at io.reactivex.internal.operators.flowable.FlowableConcatArray$ConcatArraySubscriber.onComplete(FlowableConcatArray.java:112)
at io.reactivex.internal.subscribers.BasicFuseableSubscriber.onComplete(BasicFuseableSubscriber.java:120)
at io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.checkTerminated(FlowableObserveOn.java:215)
at io.reactivex.internal.operators.flowable.FlowableObserveOn$ObserveOnSubscriber.runAsync(FlowableObserveOn.java:399)
at io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.run(FlowableObserveOn.java:176)
at io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker$BooleanRunnable.run(ExecutorScheduler.java:260)
at io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.run(ExecutorScheduler.java:225)
at org.infinispan.commons.util.concurrent.CallerRunsRejectOnShutdownPolicy.rejectedExecution(CallerRunsRejectOnShutdownPolicy.java:19)
at java.base/java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:825)
at java.base/java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1355)
at org.infinispan.executors.LazyInitializingExecutorService.execute(LazyInitializingExecutorService.java:138)
at io.reactivex.internal.schedulers.ExecutorScheduler$ExecutorWorker.schedule(ExecutorScheduler.java:143)
at io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.trySchedule(FlowableObserveOn.java:166)
at io.reactivex.internal.operators.flowable.FlowableObserveOn$BaseObserveOnSubscriber.onComplete(FlowableObserveOn.java:135)
at io.reactivex.internal.operators.flowable.FlowableSubscribeOn$SubscribeOnSubscriber.onComplete(FlowableSubscribeOn.java:108)
at io.reactivex.internal.operators.flowable.FlowableUsing$UsingSubscriber.onComplete(FlowableUsing.java:148)
at io.reactivex.internal.subscribers.BasicFuseableSubscriber.onComplete(BasicFuseableSubscriber.java:120)
at io.reactivex.internal.subscribers.BasicFuseableConditionalSubscriber.onComplete(BasicFuseableConditionalSubscriber.java:119)
at io.reactivex.internal.subscribers.BasicFuseableConditionalSubscriber.onComplete(BasicFuseableConditionalSubscriber.java:119)
at io.reactivex.internal.subscriptions.EmptySubscription.complete(EmptySubscription.java:69)
{noformat}
https://ci.infinispan.org/job/Infinispan/job/master/1269/
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
4 years, 9 months
[JBoss JIRA] (ISPN-10236) Hotrod client error releasing channel after server cache stop
by Dan Berindei (Jira)
[ https://issues.jboss.org/browse/ISPN-10236?page=com.atlassian.jira.plugin... ]
Dan Berindei reassigned ISPN-10236:
-----------------------------------
Sprint: DataGrid Sprint #30
Assignee: Dan Berindei
> Hotrod client error releasing channel after server cache stop
> -------------------------------------------------------------
>
> Key: ISPN-10236
> URL: https://issues.jboss.org/browse/ISPN-10236
> Project: Infinispan
> Issue Type: Bug
> Components: Test Suite - Server
> Affects Versions: 10.0.0.Beta3
> Reporter: Dan Berindei
> Assignee: Dan Berindei
> Priority: Major
> Labels: testsuite_stability
> Fix For: 10.0.0.Beta4
>
> Attachments: ISPN-10137_package_private_scope_20190524-1732_ServerFailureRetryTest-infinispan-client-hotrod.log.gz
>
>
> Random failure in {{ServerFailureRetryTest.testRetryCacheStopped}} caused by an assert statement in {{ChannelPool.release()}}.
> {noformat}
> 17:37:36,562 ERROR (testng-Test:[]) [TestSuiteProgress] Test failed: org.infinispan.client.hotrod.retry.ServerFailureRetryTest.testRetryCacheStopped
> java.lang.AssertionError: Error releasing [id: 0x5d9755e6, L:/127.0.0.1:42472 ! R:127.0.0.1/127.0.0.1:44865]
> at org.infinispan.client.hotrod.impl.transport.netty.ChannelPool.release(ChannelPool.java:170) ~[classes/:?]
> at org.infinispan.client.hotrod.impl.transport.netty.ChannelFactory.releaseChannel(ChannelFactory.java:309) ~[classes/:?]
> at org.infinispan.client.hotrod.impl.operations.HotRodOperation.releaseChannel(HotRodOperation.java:105) ~[classes/:?]
> at org.infinispan.client.hotrod.impl.operations.RetryOnFailureOperation.invoke(RetryOnFailureOperation.java:80) ~[classes/:?]
> at org.infinispan.client.hotrod.impl.transport.netty.ChannelPool.activateChannel(ChannelPool.java:217) ~[classes/:?]
> at org.infinispan.client.hotrod.impl.transport.netty.ChannelPool.acquire(ChannelPool.java:86) ~[classes/:?]
> at org.infinispan.client.hotrod.impl.transport.netty.ChannelFactory.fetchChannelAndInvoke(ChannelFactory.java:259) ~[classes/:?]
> at org.infinispan.client.hotrod.impl.transport.netty.ChannelFactory.fetchChannelAndInvoke(ChannelFactory.java:297) ~[classes/:?]
> at org.infinispan.client.hotrod.impl.operations.AbstractKeyOperation.fetchChannelAndInvoke(AbstractKeyOperation.java:41) ~[classes/:?]
> at org.infinispan.client.hotrod.impl.operations.RetryOnFailureOperation.execute(RetryOnFailureOperation.java:61) ~[classes/:?]
> at org.infinispan.client.hotrod.impl.RemoteCacheImpl.putAsync(RemoteCacheImpl.java:366) ~[classes/:?]
> at org.infinispan.client.hotrod.impl.RemoteCacheImpl.put(RemoteCacheImpl.java:334) ~[classes/:?]
> at org.infinispan.client.hotrod.impl.RemoteCacheSupport.put(RemoteCacheSupport.java:79) ~[classes/:?]
> at org.infinispan.client.hotrod.retry.ServerFailureRetryTest.testRetryCacheStopped(ServerFailureRetryTest.java:63) ~[test-classes/:?]
> {noformat}
> I investigated a bit and I couldn't find an obvious mistake in the way {{ChannelPool.created}} is incremented and decremented, but I think it would help if access to it and {{ChannelPool.active}} were centralized in a smaller number of methods.
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
4 years, 9 months
[JBoss JIRA] (ISPN-9704) REST fine grained security support
by Gustavo Fernandes (Jira)
[ https://issues.jboss.org/browse/ISPN-9704?page=com.atlassian.jira.plugin.... ]
Gustavo Fernandes reassigned ISPN-9704:
---------------------------------------
Assignee: (was: Gustavo Fernandes)
> REST fine grained security support
> ----------------------------------
>
> Key: ISPN-9704
> URL: https://issues.jboss.org/browse/ISPN-9704
> Project: Infinispan
> Issue Type: Feature Request
> Reporter: Gustavo Fernandes
> Priority: Major
>
> Currently the REST server requires authentication but does not offer authorization capabilities. The new REST API described in ISPN-8535 requires that invocations on resources can be restricted on a per user/role basis.
> Examples:
> /GET on /rest/v2/{cacheName} should be allowed for all authenticated users
> /POST on /rest/v2/{cacheName} should be restricted to users having the ADMIN role
--
This message was sent by Atlassian Jira
(v7.12.1#712002)
4 years, 9 months