May 2012 - infinispan-issues - Jboss List Archives

[JBoss JIRA] Created: (ISPN-1294) Run local operations from a DistributedExecutor in parallel

by Sanne Grinovero (JIRA)

Run local operations from a DistributedExecutor in parallel ----------------------------------------------------------- Key: ISPN-1294 URL: https://issues.jboss.org/browse/ISPN-1294 Project: Infinispan Issue Type: Enhancement Reporter: Sanne Grinovero Assignee: Manik Surtani Fix For: 5.1.0.ALPHA1 Looking into {code}org.infinispan.distexec.DefaultExecutorService.invokeLocally(DistributedRunnableFuture<T>){code} It seems that the operations are performed in the same thread as the invoker; if we happen to send multiple operations to the local node, these are performed in sequence, and in sequence with the remote operations. We should use an Executor for the local tasks. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira

12 years, 3 months

4
3
0 / 0

[JBoss JIRA] (ISPN-1589) Add ability to provide input keys to DistributedExecutionCompletionService.

by Erik Salter (Created) (JIRA)

Add ability to provide input keys to DistributedExecutionCompletionService. --------------------------------------------------------------------------- Key: ISPN-1589 URL: https://issues.jboss.org/browse/ISPN-1589 Project: Infinispan Issue Type: Feature Request Reporter: Erik Salter Assignee: Manik Surtani As described on the forums -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.jboss.org/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira

12 years, 3 months

5
7
0 / 0

[JBoss JIRA] (ISPN-1636) Have remoted tasks inject services via CDI before execution

by Sanne Grinovero (Created) (JIRA)

Have remoted tasks inject services via CDI before execution ----------------------------------------------------------- Key: ISPN-1636 URL: https://issues.jboss.org/browse/ISPN-1636 Project: Infinispan Issue Type: Feature Request Components: CDI integration, Core API Reporter: Sanne Grinovero Assignee: Pete Muir Fix For: 6.0.0.FINAL Second step if what was discussed on: http://infinispan.markmail.org/search/#query:+page:1+mid:3dqf7hvuabttkqli... http://community.jboss.org/message/642300#642300 ISPN-1634 should provide Cache references only, this one should provide anything the CDI container knows about as defined by injection points in the remoted tasks; injection should happen again on each node, avoiding serialization of the injected components. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.jboss.org/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira

12 years, 3 months

7
15
0 / 0

[JBoss JIRA] (ISPN-1634) Provide references to Cache to distributed executor tasks and MapReduce tasks

by Sanne Grinovero (Created) (JIRA)

Provide references to Cache to distributed executor tasks and MapReduce tasks ----------------------------------------------------------------------------- Key: ISPN-1634 URL: https://issues.jboss.org/browse/ISPN-1634 Project: Infinispan Issue Type: Enhancement Reporter: Sanne Grinovero Assignee: Manik Surtani Fix For: 5.1.0.FINAL As discussed on: http://infinispan.markmail.org/search/#query:+page:1+mid:3dqf7hvuabttkqli... http://community.jboss.org/message/642300#642300 Tasks being deserialized on remote nodes might need a reference to the Cache they are executed on; should be very useful both for distributed executer and for Map/Reduce use cases. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.jboss.org/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira

12 years, 3 months

3
6
0 / 0

[JBoss JIRA] (ISPN-1665) Add combiner function to MapReduce

by Ondrej Nevelik (Created) (JIRA)

Add combiner function to MapReduce ---------------------------------- Key: ISPN-1665 URL: https://issues.jboss.org/browse/ISPN-1665 Project: Infinispan Issue Type: Feature Request Reporter: Ondrej Nevelik Assignee: Vladimir Blagojevic Add functionality to optionally use a combiner between Map and Reduce phases (see http://research.google.com/archive/mapreduce.html part 4.3 Combiner Function). This enables to adjust API to be less restrictive - Reduce.reduce function could consume and return different types of objects. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.jboss.org/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira

12 years, 3 months

4
3
0 / 0

[JBoss JIRA] (ISPN-1886) DistributedExecutorService not working with non distributed cache

by Galder Zamarreño (JIRA)

Galder Zamarreño created ISPN-1886: -------------------------------------- Summary: DistributedExecutorService not working with non distributed cache Key: ISPN-1886 URL: https://issues.jboss.org/browse/ISPN-1886 Project: Infinispan Issue Type: Bug Affects Versions: 5.1.1.FINAL Reporter: Galder Zamarreño Assignee: Vladimir Blagojevic Fix For: 5.1.2.CR1, 5.1.2.FINAL 1) using DistributedExecutorService::submit with non <distributable-cache> results in NPE protected <K> Map<Address, List<K>> mapKeysToNodes(K... input) { DistributionManager dm = cache.getDistributionManager(); Map<Address, List<K>> addressToKey = new HashMap<Address, List<K>>(input.length * 2); for (K key : input) { Address ownerOfKey = dm.getPrimaryLocation(key); // <------- dm is null -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.jboss.org/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira

12 years, 3 months

2
5
0 / 0

[JBoss JIRA] (ISPN-1984) DistributedExecutorService#submitEverywhere fails in REPL_SYNC mode

by Vladimir Blagojevic (JIRA)

Vladimir Blagojevic created ISPN-1984: ----------------------------------------- Summary: DistributedExecutorService#submitEverywhere fails in REPL_SYNC mode Key: ISPN-1984 URL: https://issues.jboss.org/browse/ISPN-1984 Project: Infinispan Issue Type: Bug Components: Distributed Cache Affects Versions: 5.1.2.FINAL, 5.1.1.FINAL, 5.1.0.FINAL Reporter: Vladimir Blagojevic Assignee: Vladimir Blagojevic Fix For: 5.2.0.FINAL DistributedExecutorService#submitEverywhere fails in REPL_SYNC mode while it works in DIST_SYNC. For some reason the response from the node submitting the task itself is always null therefore throwing exception to caller thread of DistributedExecutorService#submitEverywhere. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.jboss.org/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira

12 years, 3 months

2
4
0 / 0

[JBoss JIRA] (ISPN-1974) Add <T> Future<T> submit(Address target, Callable<T> task) at least to DefaultExecutorService

by Thomas Fromm (JIRA)

Thomas Fromm created ISPN-1974: ---------------------------------- Summary: Add <T> Future<T> submit(Address target, Callable<T> task) at least to DefaultExecutorService Key: ISPN-1974 URL: https://issues.jboss.org/browse/ISPN-1974 Project: Infinispan Issue Type: Enhancement Components: Core API Affects Versions: 5.1.3.FINAL Reporter: Thomas Fromm Assignee: Manik Surtani To easy execute tasks on specific nodes I'd like to have an additional method at DefaultExecutorService: {code} public <T> Future<T> submit(Address target, Callable<T> task){ if (task == null) throw new NullPointerException(); if (target == null) throw new NullPointerException(); List<Address> members = rpc.getTransport().getMembers(); if(!members.contains(target)){ throw new IllegalArgumentException("Unknown node "+target.toString()); } Address me = rpc.getAddress(); DistributedExecuteCommand<T> c = null; if(target.equals(me)){ c = factory.buildDistributedExecuteCommand(clone(task), me, null); } else { c = factory.buildDistributedExecuteCommand(task, me, null); } DistributedRunnableFuture<T> f = new DistributedRunnableFuture<T>(c); executeFuture(target, f); return f; } {code} -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.jboss.org/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira

12 years, 3 months

4
4
0 / 0

[JBoss JIRA] (ISPN-2039) Iteration in DistributedTaskLifecycleService using ServiceLoader fails

by Vladimir Blagojevic (JIRA)

Vladimir Blagojevic created ISPN-2039: ----------------------------------------- Summary: Iteration in DistributedTaskLifecycleService using ServiceLoader fails Key: ISPN-2039 URL: https://issues.jboss.org/browse/ISPN-2039 Project: Infinispan Issue Type: Bug Components: Distributed Cache Affects Versions: 5.1.4.FINAL Environment: This problem has been observed in AS 7 environment rather than Infinispan standalone Reporter: Ales Justin Assignee: Vladimir Blagojevic Priority: Minor Fix For: 5.2.0.ALPHA1, 5.2.0.FINAL For some unknown reason iteration over available DistributedTaskLifecycle services in DistributedTaskLifecycleService fails, and it fails only in AS environment: Caused by: java.util.NoSuchElementException at java.util.AbstractList$Itr.next(AbstractList.java:350) [classes.jar:1.6.0_31] at java.util.Collections$1.nextElement(Collections.java:3389) [classes.jar:1.6.0_31] at java.util.ServiceLoader$LazyIterator.hasNext(ServiceLoader.java:332) [classes.jar:1.6.0_31] at java.util.ServiceLoader$1.hasNext(ServiceLoader.java:415) [classes.jar:1.6.0_31] at org.infinispan.distexec.spi.DistributedTaskLifecycleService.onPreExecute(DistributedTaskLifecycleService.java:50) [infinispan-core-5.2.0-SNAPSHOT.jar:5.2.0-SNAPSHOT] public <T> void onPreExecute(Callable<T> task) { try { Iterator<DistributedTaskLifecycle> i = loader.iterator(); while (i.hasNext()) { // <------------------------------------------------- we CHECK before DistributedTaskLifecycle cl = i.next(); cl.onPreExecute(task); -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.jboss.org/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira

12 years, 3 months

3
4
0 / 0

[JBoss JIRA] (ISPN-2037) Map/Reduce tasks should process entries in the CacheLoader as well

by Sanne Grinovero (JIRA)

Sanne Grinovero created ISPN-2037: ------------------------------------- Summary: Map/Reduce tasks should process entries in the CacheLoader as well Key: ISPN-2037 URL: https://issues.jboss.org/browse/ISPN-2037 Project: Infinispan Issue Type: Feature Request Reporter: Sanne Grinovero Assignee: Vladimir Blagojevic Fix For: 5.2.0.FINAL -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.jboss.org/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira

12 years, 3 months

4
9
0 / 0

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

infinispan-issues May 2012