GG-12190 Backported to 803ea8.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/b39f7c8d Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/b39f7c8d Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/b39f7c8d Branch: refs/heads/ignite-5398 Commit: b39f7c8d4f486f25e48a812e4a9d5aa4bbb5932f Parents: f007856 Author: Alexey Kuznetsov <[email protected]> Authored: Sat May 13 22:37:25 2017 +0700 Committer: Alexey Kuznetsov <[email protected]> Committed: Sat May 13 22:37:25 2017 +0700 ---------------------------------------------------------------------- .../apache/ignite/internal/visor/VisorMultiNodeTask.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/b39f7c8d/modules/core/src/main/java/org/apache/ignite/internal/visor/VisorMultiNodeTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/VisorMultiNodeTask.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/VisorMultiNodeTask.java index ece1a17..b50446c 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/visor/VisorMultiNodeTask.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/VisorMultiNodeTask.java @@ -80,6 +80,13 @@ public abstract class VisorMultiNodeTask<A, R, J> implements ComputeTask<VisorTa } /** + * @return Collection of nodes IDs where jobs should be mapped. + */ + protected Collection<UUID> jobNodes(VisorTaskArgument<A> arg) { + return arg.nodes(); + } + + /** * Actual map logic. * * @param arg Task execution argument. @@ -88,7 +95,7 @@ public abstract class VisorMultiNodeTask<A, R, J> implements ComputeTask<VisorTa * @throws IgniteException If mapping could not complete successfully. */ protected Map<? extends ComputeJob, ClusterNode> map0(List<ClusterNode> subgrid, VisorTaskArgument<A> arg) { - Collection<UUID> nodeIds = arg.nodes(); + Collection<UUID> nodeIds = jobNodes(arg); Map<ComputeJob, ClusterNode> map = U.newHashMap(nodeIds.size());
