ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sevdoki...@apache.org
Subject [45/50] [abbrv] incubator-ignite git commit: Merge branch ignite-sql-tests into ignite-45
Date Mon, 16 Mar 2015 09:23:32 GMT
Merge branch ignite-sql-tests into ignite-45


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

Branch: refs/heads/ignite-421
Commit: 5d2de377e785ec8a6b63f9fa7221d4ad4d2250df
Parents: b87eefa
Author: Alexey Goncharuk <agoncharuk@gridgain.com>
Authored: Sun Mar 15 22:27:00 2015 -0700
Committer: Alexey Goncharuk <agoncharuk@gridgain.com>
Committed: Sun Mar 15 22:27:00 2015 -0700

----------------------------------------------------------------------
 .../ignite/internal/processors/cache/IgniteCacheProxy.java       | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/5d2de377/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java
index d85a38c..1db55be 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxy.java
@@ -451,9 +451,7 @@ public class IgniteCacheProxy<K, V> extends AsyncSupportAdapter<IgniteCache<K,
V
         if (!ctx.isReplicated())
             return false;
 
-        ClusterGroup grp = ctx.kernalContext().grid().cluster().forDataNodes(ctx.name());
-
-        return grp.node(ctx.localNodeId()) != null;
+        return ctx.affinityNode();
     }
 
     /** {@inheritDoc} */


Mime
View raw message