GG-11898 Fixed VisorSnapshotsStatusTask.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/94a30533 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/94a30533 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/94a30533 Branch: refs/heads/ignite-5075-pds Commit: 94a305332882113bc68e6feb0263d104f0c673ad Parents: c4deff8 Author: Alexey Kuznetsov <[email protected]> Authored: Fri May 12 16:31:04 2017 +0700 Committer: Alexey Kuznetsov <[email protected]> Committed: Fri May 12 16:31:04 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/94a30533/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 563a236..89a5fcf 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.getNodes(); + } + + /** * 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.getNodes(); + Collection<UUID> nodeIds = jobNodes(arg); Map<ComputeJob, ClusterNode> map = U.newHashMap(nodeIds.size());
