ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From agoncha...@apache.org
Subject [07/49] ignite git commit: GG-12190 Backported to 803ea8.
Date Fri, 02 Jun 2017 17:13:20 GMT
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 <akuznetsov@gridgain.com>
Authored: Sat May 13 22:37:25 2017 +0700
Committer: Alexey Kuznetsov <akuznetsov@gridgain.com>
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());
 


Mime
View raw message