ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From agoncha...@apache.org
Subject [27/31] incubator-ignite git commit: # sprint-3 Fixed Visor tests.
Date Sat, 11 Apr 2015 07:47:59 GMT
# sprint-3 Fixed Visor tests.


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

Branch: refs/heads/ignite-721
Commit: 1a5990c99536580ad934cd916fc64695c86b9350
Parents: 5953786
Author: AKuznetsov <akuznetsov@gridgain.com>
Authored: Sat Apr 11 09:51:17 2015 +0700
Committer: AKuznetsov <akuznetsov@gridgain.com>
Committed: Sat Apr 11 09:51:17 2015 +0700

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


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1a5990c9/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 b320842..6683205 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,7 +44,9 @@ public class VisorQueryTask extends VisorOneNodeTask<VisorQueryArg, IgniteBiTupl
         ClusterNode node;
 
         if (taskArg.localCacheNodeId() == null) {
-            ClusterGroup prj = ignite.cluster().forDataNodes(cacheName);
+            ClusterGroup prj = (ignite.cluster().localNode().isDaemon())
+                ? ignite.cluster().forRemotes()
+                : ignite.cluster().forDataNodes(cacheName);
 
             if (prj.nodes().isEmpty())
                 throw new IgniteException("No data nodes for cache: " + escapeName(cacheName));


Mime
View raw message