ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From akuznet...@apache.org
Subject [5/8] ignite git commit: VisorGatewayTask should be aware of passed nodes IDs.
Date Thu, 07 Jul 2016 14:01:52 GMT
 VisorGatewayTask should be aware of passed nodes IDs.


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/5d9f899c
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/5d9f899c
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/5d9f899c

Branch: refs/heads/ignite-3443
Commit: 5d9f899c15e44d1860e4c5d8fd8bf69c91228de9
Parents: c35c652
Author: Alexey Kuznetsov <akuznetsov@apache.org>
Authored: Wed Jul 6 18:52:13 2016 +0700
Committer: Alexey Kuznetsov <akuznetsov@apache.org>
Committed: Wed Jul 6 18:52:13 2016 +0700

----------------------------------------------------------------------
 .../apache/ignite/internal/visor/compute/VisorGatewayTask.java    | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/5d9f899c/modules/core/src/main/java/org/apache/ignite/internal/visor/compute/VisorGatewayTask.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/compute/VisorGatewayTask.java
b/modules/core/src/main/java/org/apache/ignite/internal/visor/compute/VisorGatewayTask.java
index f1d6c85..2539a26 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/compute/VisorGatewayTask.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/compute/VisorGatewayTask.java
@@ -355,7 +355,8 @@ public class VisorGatewayTask implements ComputeTask<Object[], Object>
{
                 }
             }
 
-            return ignite.compute().execute(taskName, new VisorTaskArgument<>(nids,
jobArgs, false));
+            return ignite.compute(ignite.cluster().forNodeIds(nids))
+                .execute(taskName, new VisorTaskArgument<>(nids, jobArgs, false));
         }
     }
 }


Mime
View raw message