[infinispan-issues] [JBoss JIRA] (ISPN-6306) Distributed Streams should also be used for Replication Cache

[Gustavo Fernandes (JIRA)]

    [ https://issues.jboss.org/browse/ISPN-6306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13172912#comment-13172912 ] 

Gustavo Fernandes commented on ISPN-6306:
-----------------------------------------

There are some side-effects of the changes introduced:

{code}
14:13:54,212 ERROR (testng-DistributedCacheClusteredQueryTest) [InvocationContextInterceptor] ISPN000136: Error executing command ClearCommand, writing keys []
org.infinispan.commons.CacheException: java.lang.UnsupportedOperationException
	at org.infinispan.stream.impl.DistributedCacheStream.lambda$rehashAwareIteration$109(DistributedCacheStream.java:578)
	at org.infinispan.stream.impl.DistributedCacheStream$$Lambda$51/1093124816.run(Unknown Source)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
	at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.UnsupportedOperationException
	at java.util.Collections$UnmodifiableCollection.retainAll(Collections.java:1071)
	at org.infinispan.stream.impl.DistributedCacheStream.performLocalRehashAwareOperation(DistributedCacheStream.java:611)
	at org.infinispan.stream.impl.DistributedCacheStream.lambda$rehashAwareIteration$109(DistributedCacheStream.java:568)[UnitTestTestNGListener] Test testLazyIteratorWithOffset(org.infinispan.query.blackbox.CompatModeLocalCacheTest) succeeded.

{code}

> Distributed Streams should also be used for Replication Cache
> -------------------------------------------------------------
>
>                 Key: ISPN-6306
>                 URL: https://issues.jboss.org/browse/ISPN-6306
>             Project: Infinispan
>          Issue Type: Bug
>          Components: Distributed Execution and Map/Reduce
>    Affects Versions: 8.2.0.CR1
>            Reporter: William Burns
>            Assignee: William Burns
>             Fix For: 8.2.0.Final
>
>
> Currently Replication is treated as a local cache.  However we should use Distributed Stream by default.  A user can force it to process locally in a Replcation cache by using Flag.CACHE_MODE_LOCAL on an advanced cache.



--
This message was sent by Atlassian JIRA
(v6.4.11#64026)