May 2020 - infinispan-issues - Jboss List Archives

[JBoss JIRA] (ISPN-11853) Error and Log handling in REST

by Will Burns (Jira)

[ https://issues.redhat.com/browse/ISPN-11853?page=com.atlassian.jira.plugi... ] Will Burns commented on ISPN-11853: ----------------------------------- I am not 100% on the safety, however, I would be very surprised that there isn't some sort of happens before occurring between there. I believe the BlockingQueue put and take would satisfy this, the more I think about it. https://docs.oracle.com/javase/8/docs/api/java/util/concurrent/package-su... "Actions in a thread prior to placing an object into any concurrent collection happen-before actions subsequent to the access or removal of that element from the collection in another thread." > Error and Log handling in REST > ------------------------------ > > Key: ISPN-11853 > URL: https://issues.redhat.com/browse/ISPN-11853 > Project: Infinispan > Issue Type: Enhancement > Components: REST > Affects Versions: 10.1.8.Final > Reporter: Katia Aresti > Assignee: Gustavo Fernandes > Priority: Major > Labels: rest > > The consistency of the errors handling in the REST endpoint is not even in all the resources, and the completion stage should deal with exceptions raised instead of throwing them directly from the method > Logs are missing in the REST endpoints, specially trace logs, which makes debugging in production hard > Finally the NettyRestResponse.Builder apparently is not thread safe, so would be better to make it thread safe -- This message was sent by Atlassian Jira (v7.13.8#713008)

4 years, 5 months

1
0
0 / 0

[JBoss JIRA] (ISPN-11874) ClusterPublisher can get NPE during topology change with ScatteredCache

by Will Burns (Jira)

Will Burns created ISPN-11874: --------------------------------- Summary: ClusterPublisher can get NPE during topology change with ScatteredCache Key: ISPN-11874 URL: https://issues.redhat.com/browse/ISPN-11874 Project: Infinispan Issue Type: Bug Affects Versions: 11.0.0.Dev05 Reporter: Will Burns Scattered cache can have topologies that don't have a primary owner for a segment. Currently ClusterPublisher assumes every segment has a primary owner. We need to wait for the next topology again if a segment doesn't yet have a primary owner. Here is a sample stack trace of it occurring. {code} java.lang.NullPointerException at org.infinispan.remoting.transport.jgroups.JGroupsTransport.invokeCommand(JGroupsTransport.java:876) at org.infinispan.remoting.rpc.RpcManagerImpl.invokeCommand(RpcManagerImpl.java:149) at org.infinispan.reactive.publisher.impl.ClusterPublisherManagerImpl$SubscriberHandler.sendInitialCommand(ClusterPublisherManagerImpl.java:1034) at org.infinispan.reactive.publisher.impl.InnerPublisherSubscription.accept(InnerPublisherSubscription.java:136) at io.reactivex.rxjava3.internal.operators.flowable.FlowableDoOnLifecycle$SubscriptionLambdaSubscriber.request(FlowableDoOnLifecycle.java:101) at io.reactivex.rxjava3.internal.subscriptions.SubscriptionArbiter.setSubscription(SubscriptionArbiter.java:99) at io.reactivex.rxjava3.internal.operators.flowable.FlowableRepeatUntil$RepeatSubscriber.onSubscribe(FlowableRepeatUntil.java:61) at io.reactivex.rxjava3.internal.operators.flowable.FlowableDoOnLifecycle$SubscriptionLambdaSubscriber.onSubscribe(FlowableDoOnLifecycle.java:73) at io.reactivex.rxjava3.processors.UnicastProcessor.subscribeActual(UnicastProcessor.java:481) 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$RepeatSubscriber.onComplete(FlowableRepeatUntil.java:88) at io.reactivex.rxjava3.internal.operators.flowable.FlowableFromCompletable$FromCompletableObserver.onComplete(FlowableFromCompletable.java:77) at io.reactivex.rxjava3.internal.jdk8.CompletableFromCompletionStage$CompletionStageHandler.accept(CompletableFromCompletionStage.java:64) at io.reactivex.rxjava3.internal.jdk8.CompletableFromCompletionStage$CompletionStageHandler.accept(CompletableFromCompletionStage.java:47) at io.reactivex.rxjava3.internal.jdk8.FlowableFromCompletionStage$BiConsumerAtomicReference.accept(FlowableFromCompletionStage.java:90) at io.reactivex.rxjava3.internal.jdk8.FlowableFromCompletionStage$BiConsumerAtomicReference.accept(FlowableFromCompletionStage.java:81) 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 org.infinispan.statetransfer.StateTransferLockImpl.notifyTopologyInstalled(StateTransferLockImpl.java:137) at org.infinispan.statetransfer.StateConsumerImpl.lambda$onTopologyUpdate$1(StateConsumerImpl.java:342) at java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106) at java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235) at java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143) at org.infinispan.statetransfer.StateConsumerImpl.onTopologyUpdate(StateConsumerImpl.java:322) at org.infinispan.scattered.impl.ScatteredStateConsumerImpl.onTopologyUpdate(ScatteredStateConsumerImpl.java:100) at org.infinispan.statetransfer.StateTransferManagerImpl.updateProviderAndConsumer(StateTransferManagerImpl.java:206) at org.infinispan.statetransfer.StateTransferManagerImpl.lambda$doTopologyUpdate$0(StateTransferManagerImpl.java:193) at java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106) at java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235) at java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143) at org.infinispan.statetransfer.StateTransferManagerImpl.doTopologyUpdate(StateTransferManagerImpl.java:192) at org.infinispan.statetransfer.StateTransferManagerImpl.access$000(StateTransferManagerImpl.java:68) at org.infinispan.statetransfer.StateTransferManagerImpl$1.updateConsistentHash(StateTransferManagerImpl.java:123) at org.infinispan.topology.LocalTopologyManagerImpl.lambda$doHandleTopologyUpdate$12(LocalTopologyManagerImpl.java:399) at java.base/java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:1106) at java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2235) at java.base/java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:143) at org.infinispan.topology.LocalTopologyManagerImpl.doHandleTopologyUpdate(LocalTopologyManagerImpl.java:388) at org.infinispan.topology.LocalTopologyManagerImpl.lambda$handleTopologyUpdate$8(LocalTopologyManagerImpl.java:312) at org.infinispan.topology.LocalTopologyManagerImpl.lambda$orderOnCache$24(LocalTopologyManagerImpl.java:737) at org.infinispan.util.concurrent.ActionSequencer.safeNonBlockingCall(ActionSequencer.java:57) at org.infinispan.util.concurrent.ActionSequencer.access$400(ActionSequencer.java:32) at org.infinispan.util.concurrent.ActionSequencer$SequenceEntry.run(ActionSequencer.java:226) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) {code} -- This message was sent by Atlassian Jira (v7.13.8#713008)

4 years, 5 months

1
0
0 / 0

[JBoss JIRA] (ISPN-9469) Implement timeout for clustered queries

by Gustavo Fernandes (Jira)

[ https://issues.redhat.com/browse/ISPN-9469?page=com.atlassian.jira.plugin... ] Gustavo Fernandes updated ISPN-9469: ------------------------------------ Affects Version/s: 11.0.0.Dev05 > Implement timeout for clustered queries > --------------------------------------- > > Key: ISPN-9469 > URL: https://issues.redhat.com/browse/ISPN-9469 > Project: Infinispan > Issue Type: Enhancement > Components: Embedded Querying > Affects Versions: 11.0.0.Dev05 > Reporter: Nistor Adrian > Assignee: Gustavo Fernandes > Priority: Major > Labels: query-ispn11 > Fix For: 11.0.0.Final > > > See TODO comment in ClusteredCacheQueryImpl.timeout(..) code. -- This message was sent by Atlassian Jira (v7.13.8#713008)

4 years, 5 months

1
0
0 / 0

[JBoss JIRA] (ISPN-9469) Implement timeout for clustered queries

by Gustavo Fernandes (Jira)

[ https://issues.redhat.com/browse/ISPN-9469?page=com.atlassian.jira.plugin... ] Gustavo Fernandes updated ISPN-9469: ------------------------------------ Fix Version/s: 11.0.0.Final > Implement timeout for clustered queries > --------------------------------------- > > Key: ISPN-9469 > URL: https://issues.redhat.com/browse/ISPN-9469 > Project: Infinispan > Issue Type: Enhancement > Components: Embedded Querying > Affects Versions: 11.0.0.Dev05 > Reporter: Nistor Adrian > Assignee: Gustavo Fernandes > Priority: Major > Labels: query-ispn11 > Fix For: 11.0.0.Final > > > See TODO comment in ClusteredCacheQueryImpl.timeout(..) code. -- This message was sent by Atlassian Jira (v7.13.8#713008)

4 years, 5 months

1
0
0 / 0

[JBoss JIRA] (ISPN-9469) Implement timeout for clustered queries

by Gustavo Fernandes (Jira)

[ https://issues.redhat.com/browse/ISPN-9469?page=com.atlassian.jira.plugin... ] Work on ISPN-9469 started by Gustavo Fernandes. ----------------------------------------------- > Implement timeout for clustered queries > --------------------------------------- > > Key: ISPN-9469 > URL: https://issues.redhat.com/browse/ISPN-9469 > Project: Infinispan > Issue Type: Enhancement > Components: Embedded Querying > Affects Versions: 11.0.0.Dev05 > Reporter: Nistor Adrian > Assignee: Gustavo Fernandes > Priority: Major > Labels: query-ispn11 > Fix For: 11.0.0.Final > > > See TODO comment in ClusteredCacheQueryImpl.timeout(..) code. -- This message was sent by Atlassian Jira (v7.13.8#713008)

4 years, 5 months

1
0
0 / 0

[JBoss JIRA] (ISPN-9469) Implement timeout for clustered queries

by Gustavo Fernandes (Jira)

[ https://issues.redhat.com/browse/ISPN-9469?page=com.atlassian.jira.plugin... ] Gustavo Fernandes reassigned ISPN-9469: --------------------------------------- Assignee: Gustavo Fernandes > Implement timeout for clustered queries > --------------------------------------- > > Key: ISPN-9469 > URL: https://issues.redhat.com/browse/ISPN-9469 > Project: Infinispan > Issue Type: Enhancement > Components: Embedded Querying > Affects Versions: 11.0.0.Dev05 > Reporter: Nistor Adrian > Assignee: Gustavo Fernandes > Priority: Major > Labels: query-ispn11 > Fix For: 11.0.0.Final > > > See TODO comment in ClusteredCacheQueryImpl.timeout(..) code. -- This message was sent by Atlassian Jira (v7.13.8#713008)

4 years, 5 months

1
0
0 / 0

[JBoss JIRA] (ISPN-9466) org.infinispan.query.clustered.QueryBox does not implement eviction for zombie iterators

by Gustavo Fernandes (Jira)

[ https://issues.redhat.com/browse/ISPN-9466?page=com.atlassian.jira.plugin... ] Gustavo Fernandes closed ISPN-9466. ----------------------------------- Resolution: Won't Fix > org.infinispan.query.clustered.QueryBox does not implement eviction for zombie iterators > ---------------------------------------------------------------------------------------- > > Key: ISPN-9466 > URL: https://issues.redhat.com/browse/ISPN-9466 > Project: Infinispan > Issue Type: Task > Components: Embedded Querying > Reporter: Nistor Adrian > Assignee: Gustavo Fernandes > Priority: Major > Labels: query-ispn11 > > Although the javadoc hints to some eviction mechanism this is not actually implemented. > A linked list 'ageOrderedQueries' is maintained so that active queries move to the head of the list and the list is limited to 3000 items. Still, there is no mechanism that actually removes the zombie queries from the 'queries' ConcurrentMap. -- This message was sent by Atlassian Jira (v7.13.8#713008)

4 years, 5 months

1
0
0 / 0

[JBoss JIRA] (ISPN-9466) org.infinispan.query.clustered.QueryBox does not implement eviction for zombie iterators

by Gustavo Fernandes (Jira)

[ https://issues.redhat.com/browse/ISPN-9466?page=com.atlassian.jira.plugin... ] Gustavo Fernandes commented on ISPN-9466: ----------------------------------------- The QueryBox component is only used when doing CacheQuery with the LAZY param, such as {code:java} cacheQuery.iterator(new FetchOptions().fetchMode(FetchOptions.FetchMode.LAZY) {code} Since lazy iterators only makes sense with distributed Lucene Queries, and CacheQuery is being deprecated in ISPN 11 (replaced by Query that is index agnostic), I am going to close this issue. > org.infinispan.query.clustered.QueryBox does not implement eviction for zombie iterators > ---------------------------------------------------------------------------------------- > > Key: ISPN-9466 > URL: https://issues.redhat.com/browse/ISPN-9466 > Project: Infinispan > Issue Type: Task > Components: Embedded Querying > Reporter: Nistor Adrian > Assignee: Gustavo Fernandes > Priority: Major > Labels: query-ispn11 > > Although the javadoc hints to some eviction mechanism this is not actually implemented. > A linked list 'ageOrderedQueries' is maintained so that active queries move to the head of the list and the list is limited to 3000 items. Still, there is no mechanism that actually removes the zombie queries from the 'queries' ConcurrentMap. -- This message was sent by Atlassian Jira (v7.13.8#713008)

4 years, 5 months

1
0
0 / 0

[JBoss JIRA] (ISPN-11873) Add report failure for RxJava Undelivered Errors

by Will Burns (Jira)

[ https://issues.redhat.com/browse/ISPN-11873?page=com.atlassian.jira.plugi... ] Will Burns updated ISPN-11873: ------------------------------ Status: Pull Request Sent (was: Coding In Progress) Git Pull Request: https://github.com/infinispan/infinispan/pull/8356 > Add report failure for RxJava Undelivered Errors > ------------------------------------------------ > > Key: ISPN-11873 > URL: https://issues.redhat.com/browse/ISPN-11873 > Project: Infinispan > Issue Type: Bug > Components: Test Suite > Reporter: Will Burns > Assignee: Will Burns > Priority: Major > Fix For: 11.0.0.CR1 > > > We should install an error handler into RxJava during the test suite so that if we get any undelivered exceptions they will be reported, similar to uncaught exception handler that was added. -- This message was sent by Atlassian Jira (v7.13.8#713008)

4 years, 5 months

1
0
0 / 0

[JBoss JIRA] (ISPN-11873) Add report failure for RxJava Undelivered Errors

by Will Burns (Jira)

[ https://issues.redhat.com/browse/ISPN-11873?page=com.atlassian.jira.plugi... ] Will Burns updated ISPN-11873: ------------------------------ Status: Open (was: New) > Add report failure for RxJava Undelivered Errors > ------------------------------------------------ > > Key: ISPN-11873 > URL: https://issues.redhat.com/browse/ISPN-11873 > Project: Infinispan > Issue Type: Bug > Components: Test Suite > Reporter: Will Burns > Assignee: Will Burns > Priority: Major > Fix For: 11.0.0.CR1 > > > We should install an error handler into RxJava during the test suite so that if we get any undelivered exceptions they will be reported, similar to uncaught exception handler that was added. -- This message was sent by Atlassian Jira (v7.13.8#713008)

4 years, 5 months

1
0
0 / 0

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

infinispan-issues May 2020