[JBoss JIRA] (ISPN-8651) Use functional commands for JCache operations
by Gustavo Fernandes (JIRA)
[ https://issues.jboss.org/browse/ISPN-8651?page=com.atlassian.jira.plugin.... ]
Gustavo Fernandes updated ISPN-8651:
------------------------------------
Status: Open (was: New)
> Use functional commands for JCache operations
> ---------------------------------------------
>
> Key: ISPN-8651
> URL: https://issues.jboss.org/browse/ISPN-8651
> Project: Infinispan
> Issue Type: Enhancement
> Reporter: Radim Vansa
> Assignee: Radim Vansa
>
> Some JCache operations (especially the {{invoke}}) cannot be executed using single command. We should run those using functional commands if possible.
> -Regarding the {{invoke}} we have to find out if the {{EntryProcessor}} is marshallable. If it is we will assume that it does not have any side-effect and can be invoked on remote node; we should let the user opt-out of this behaviour through a system property.-
> JSR107 spec says that implementation may require the EntryProcessor to be serializable or marshallable in some manner.
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
6 years, 3 months
[JBoss JIRA] (ISPN-8651) Use functional commands for JCache operations
by Gustavo Fernandes (JIRA)
[ https://issues.jboss.org/browse/ISPN-8651?page=com.atlassian.jira.plugin.... ]
Gustavo Fernandes updated ISPN-8651:
------------------------------------
Status: Pull Request Sent (was: Open)
Git Pull Request: https://github.com/infinispan/infinispan/pull/5670
> Use functional commands for JCache operations
> ---------------------------------------------
>
> Key: ISPN-8651
> URL: https://issues.jboss.org/browse/ISPN-8651
> Project: Infinispan
> Issue Type: Enhancement
> Reporter: Radim Vansa
> Assignee: Radim Vansa
>
> Some JCache operations (especially the {{invoke}}) cannot be executed using single command. We should run those using functional commands if possible.
> -Regarding the {{invoke}} we have to find out if the {{EntryProcessor}} is marshallable. If it is we will assume that it does not have any side-effect and can be invoked on remote node; we should let the user opt-out of this behaviour through a system property.-
> JSR107 spec says that implementation may require the EntryProcessor to be serializable or marshallable in some manner.
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
6 years, 3 months
[JBoss JIRA] (ISPN-7596) org.infinispan.commons.marshall.NotSerializableException: java.util.stream.Collectors$CollectorImpl
by paragBorah Borah (JIRA)
[ https://issues.jboss.org/browse/ISPN-7596?page=com.atlassian.jira.plugin.... ]
paragBorah Borah commented on ISPN-7596:
----------------------------------------
Exceptions ::
org.infinispan.commons.marshall.NotSerializableException: java.util.stream.Collectors$CollectorImpl
ERROR 01/18 19:32:01.241 [Thread-31,EXECUTOR_POOL] c.b.t.r.t.TaskExecutionWorker Failed to build result - %s
com.bmc.truesight.rest.exception.ResultBuilderException: org.infinispan.commons.marshall.NotSerializableException: java.util.stream.Collectors$CollectorImpl
at com.bmc.truesight.wscommon.router.rsbuilder.AbstractRouterResultBuilder.buildResult(AbstractRouterResultBuilder.java:71)
at com.bmc.truesight.rest.taskexecution.TaskExecutionWorker.run(TaskExecutionWorker.java:83)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
> org.infinispan.commons.marshall.NotSerializableException: java.util.stream.Collectors$CollectorImpl
> ---------------------------------------------------------------------------------------------------
>
> Key: ISPN-7596
> URL: https://issues.jboss.org/browse/ISPN-7596
> Project: Infinispan
> Issue Type: Bug
> Components: Core
> Reporter: Gustavo Fernandes
>
> Triggered by this snipped present in {{HotRodSourceMigrator}}:
> {code:java}
> Set<byte[]> allKeys = cache.keySet();
> Set<byte[]> copy = allKeys.stream().collect(Collectors.toSet());
> {code}
--
This message was sent by Atlassian JIRA
(v7.5.0#75005)
6 years, 3 months