[JBoss JIRA] (ISPN-6271) Stream filterKeys reads keys not owned remotely when it shouldn't
by Adrian Nistor (JIRA)
[ https://issues.jboss.org/browse/ISPN-6271?page=com.atlassian.jira.plugin.... ]
Adrian Nistor updated ISPN-6271:
--------------------------------
Status: Resolved (was: Pull Request Sent)
Resolution: Done
Integrated in master. Thanks @wburns!
> Stream filterKeys reads keys not owned remotely when it shouldn't
> -----------------------------------------------------------------
>
> Key: ISPN-6271
> URL: https://issues.jboss.org/browse/ISPN-6271
> Project: Infinispan
> Issue Type: Bug
> Components: Distributed Execution and Map/Reduce
> Affects Versions: 8.1.2.Final
> Reporter: William Burns
> Assignee: William Burns
> Fix For: 8.2.0.CR1
>
>
> The filterKeys method currently isn't as performant as it should be per ISPN-6270. However this was by design for the first pass. However despite this there is an issue where when performing the stream population using the keys that it will read all non owned keys from remote owners when it shouldn't be. This is an easy fix by forcing the cache to do a LOCAL only read.
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
10 years, 1 month
[JBoss JIRA] (ISPN-6268) Deployed task is logged as "Cache Store"
by Adrian Nistor (JIRA)
[ https://issues.jboss.org/browse/ISPN-6268?page=com.atlassian.jira.plugin.... ]
Adrian Nistor updated ISPN-6268:
--------------------------------
Status: Resolved (was: Pull Request Sent)
Fix Version/s: 8.2.0.CR1
Resolution: Done
Integrated in master. Thanks!
> Deployed task is logged as "Cache Store"
> -----------------------------------------
>
> Key: ISPN-6268
> URL: https://issues.jboss.org/browse/ISPN-6268
> Project: Infinispan
> Issue Type: Bug
> Components: Server, Tasks
> Affects Versions: 8.2.0.Beta2
> Reporter: Martin Gencur
> Assignee: Martin Gencur
> Priority: Minor
> Fix For: 8.2.0.CR1
>
>
> When deploying a new task in a jar file, the server logs it as follows:
> {code}
> [Server:server-two] 16:17:25,092 INFO [org.jboss.as.server.deployment] (MSC service thread 1-2) WFLYSRV0027: Starting deployment of "local-task.jar" (runtime-name: "local-task.jar")
> [Server:server-one] 16:17:25,096 INFO [org.jboss.as.server.deployment] (MSC service thread 1-4) WFLYSRV0027: Starting deployment of "local-task.jar" (runtime-name: "local-task.jar")
> [Server:server-two] 16:17:25,112 INFO [org.jboss.as.clustering.infinispan] (MSC service thread 1-3) DGISPN0007: Registering Deployed Cache Store service for store 'com.jboss.datagrid.test.ui.tasks.LocalTask'
> [Server:server-one] 16:17:25,118 INFO [org.jboss.as.clustering.infinispan] (MSC service thread 1-7) DGISPN0007: Registering Deployed Cache Store service for store 'com.jboss.datagrid.test.ui.tasks.LocalTask'
> {code}
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
10 years, 1 month
[JBoss JIRA] (ISPN-6273) Add documentation for ClusterExecutor
by William Burns (JIRA)
William Burns created ISPN-6273:
-----------------------------------
Summary: Add documentation for ClusterExecutor
Key: ISPN-6273
URL: https://issues.jboss.org/browse/ISPN-6273
Project: Infinispan
Issue Type: Task
Components: Documentation-Core
Reporter: William Burns
Assignee: William Burns
Fix For: 8.2.0.Final
The ClusterExecutor was recently added allowing for execution of cluster wide events with the need of a cache. We need to document this.
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
10 years, 1 month
[JBoss JIRA] (ISPN-6272) Extend CacheStream interface to allow for Serializable lambdas
by William Burns (JIRA)
William Burns created ISPN-6272:
-----------------------------------
Summary: Extend CacheStream interface to allow for Serializable lambdas
Key: ISPN-6272
URL: https://issues.jboss.org/browse/ISPN-6272
Project: Infinispan
Issue Type: Enhancement
Components: Distributed Execution and Map/Reduce
Reporter: William Burns
Assignee: William Burns
Fix For: 9.0.0.Alpha1
Recently it was found that we could add multiple overrides of a method where it was using a FunctionalInterface but also make that interface extend Serializable. This would allow for provided lambdas to be instantly serializable since the JVM will pick the most specific argument.
Example:
{code}
CacheStream filter(Predicate<? super R> predicate);
{code}
vs
{code}
CacheStream filter(SerializablePredicate<? super R> predicate);
{code}
--
This message was sent by Atlassian JIRA
(v6.4.11#64026)
10 years, 1 month