[
https://issues.apache.org/jira/browse/IGNITE-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16224012#comment-16224012
]
Ihor Parashynets commented on IGNITE-5037:
------------------------------------------
[~ascherbakov]
Thank you for your response.
I actually asked some questions (including description of evaluation for my
use-case) on user list
[here|http://apache-ignite-users.70518.x6.nabble.com/Task-management-MapReduce-amp-ForkJoin-performance-penalty-td16542.html].
I got the solution, which allows to execute jobs in collocated manner... but
what I'd like to have (if I understood properly description of this ticket) is
to have this feature with help of Ignite's {{MapReduce API}} framework.
Meaning, I'd like to create a {{ComputeTask}} ({{ComputeTaskAdapter}} or
{{ComputeTaskSplitAdapter}}), which would spawn {{ComputeJob}} with affinity
key (annotation or injection) and execute them on node with co-located data.
Otherwise I'd have to create my own "structure", where I'd have to move my
"jobs" to callable/runnable objects and then run them as
affinityRunAsync/affinityCallAsync.
I thought if this ticket would be implemented I'd get really nice way to
achieve this almost out-of-the-box.
> Fix broken @AffinityKeyMapped annotation for compute jobs.
> ----------------------------------------------------------
>
> Key: IGNITE-5037
> URL: https://issues.apache.org/jira/browse/IGNITE-5037
> Project: Ignite
> Issue Type: Improvement
> Affects Versions: 1.7
> Reporter: Alexei Scherbakov
> Assignee: Maksim Kozlov
> Labels: newbie
>
> See related discussion on dev list entitled Proper collocation of
> computations and data
> (http://apache-ignite-developers.2346864.n4.nabble.com/Proper-collocation-of-computations-and-data-td16945.html).
> We must repair data affinity routing for compute jobs. It should work same as
> for affinityCall/Run with partition.
> Currently, ComputeTask map method returns Map<? extends ComputeJob,
> ClusterNode>,
> but we have to provide some API allows to map ComputeJobs to partitions or
> keys.
> This can be done using AffinityKeyMapped annotation or any other way.
> Since that's a publiŃ API any fixes should be discussed on dev list prior to
> implementation.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
