June 2012 - infinispan-issues - Jboss List Archives

[JBoss JIRA] Created: (ISPN-1039) Create DistributedExecutorService and MapReduce examples

by Vladimir Blagojevic (JIRA)

Create DistributedExecutorService and MapReduce examples --------------------------------------------------------- Key: ISPN-1039 URL: https://issues.jboss.org/browse/ISPN-1039 Project: Infinispan Issue Type: Task Components: Demos and Tutorials Affects Versions: 5.0.0.BETA1 Reporter: Vladimir Blagojevic Assignee: Vladimir Blagojevic Fix For: 5.0.0.FINAL Create at least a few examples/use cases for DistributedExecutorService and MapReduceTask. Include these examples into a test suite and include them into getting started wiki page for distributed execution framework. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira

11 years, 8 months

2
4
0 / 0

[JBoss JIRA] Created: (ISPN-1274) DefaultExecutorService uses no thread pool when it decides to invokeLocally

by Thomas Peuss (JIRA)

DefaultExecutorService uses no thread pool when it decides to invokeLocally --------------------------------------------------------------------------- Key: ISPN-1274 URL: https://issues.jboss.org/browse/ISPN-1274 Project: Infinispan Issue Type: Bug Components: Distributed Cache Affects Versions: 5.0.0.CR8 Reporter: Thomas Peuss Assignee: Manik Surtani DefaultExecutorService uses no thread pool when it decides to invokeLocally. It always uses the calling thread in this case. This leads to bad concurrency (1). -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira

11 years, 8 months

7
9
0 / 0

[JBoss JIRA] Created: (ISPN-1129) method o.i.distexec.DefaultExecutorService.invokeAny(Collection tasks) never returns

by Mikhail Khludnev (JIRA)

method o.i.distexec.DefaultExecutorService.invokeAny(Collection tasks) never returns ------------------------------------------------------------------------------------ Key: ISPN-1129 URL: https://issues.jboss.org/browse/ISPN-1129 Project: Infinispan Issue Type: Bug Components: Core API Affects Versions: 5.0.0.CR3 Reporter: Mikhail Khludnev Assignee: Manik Surtani DefaultExecutorService.invokeAny() seems not working ever just because DistributedExecutionCompletionService seems not working too, because it never attach it's listener to tasks. I made a test, but didn't find an easy approach to fix it. -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira

11 years, 8 months

3
5
0 / 0

[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

11 years, 8 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

11 years, 8 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

11 years, 8 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

11 years, 8 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

11 years, 8 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

11 years, 8 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

11 years, 8 months

2
4
0 / 0

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

infinispan-issues June 2012