You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2016/07/19 06:54:33 UTC
[05/28] ignite git commit: VisorGatewayTask should be aware of passed
nodes IDs.
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 <ak...@apache.org>
Authored: Wed Jul 6 18:52:13 2016 +0700
Committer: Alexey Kuznetsov <ak...@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));
}
}
}