You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2017/05/22 15:12:33 UTC
[05/50] [abbrv] ignite git commit: GG-11898 Fixed
VisorSnapshotsStatusTask.
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 <ak...@apache.org>
Authored: Fri May 12 16:31:04 2017 +0700
Committer: Alexey Kuznetsov <ak...@apache.org>
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());