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-3414 Commit: 5d9f899c15e44d1860e4c5d8fd8bf69c91228de9 Parents: c35c652 Author: Alexey Kuznetsov <[email protected]> Authored: Wed Jul 6 18:52:13 2016 +0700 Committer: Alexey Kuznetsov <[email protected]> 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)); } } }
