# sprint-4 Use forDataNodes() instead of forRemotes().

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

Branch: refs/heads/ignite-218
Commit: b5ebe233930981df2ae180c0a389b1111a52e7de
Parents: e15f4b9
Author: AKuznetsov <akuznet...@gridgain.com>
Authored: Wed Apr 15 06:58:59 2015 +0700
Committer: AKuznetsov <akuznet...@gridgain.com>
Committed: Wed Apr 15 06:58:59 2015 +0700

----------------------------------------------------------------------
 .../org/apache/ignite/internal/visor/query/VisorQueryTask.java   | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b5ebe233/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorQueryTask.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorQueryTask.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorQueryTask.java
index 6683205..b320842 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorQueryTask.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorQueryTask.java
@@ -44,9 +44,7 @@ public class VisorQueryTask extends 
VisorOneNodeTask<VisorQueryArg, IgniteBiTupl
         ClusterNode node;
 
         if (taskArg.localCacheNodeId() == null) {
-            ClusterGroup prj = (ignite.cluster().localNode().isDaemon())
-                ? ignite.cluster().forRemotes()
-                : ignite.cluster().forDataNodes(cacheName);
+            ClusterGroup prj = ignite.cluster().forDataNodes(cacheName);
 
             if (prj.nodes().isEmpty())
                 throw new IgniteException("No data nodes for cache: " + 
escapeName(cacheName));

Reply via email to