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-45 Commit: 5d2de377e785ec8a6b63f9fa7221d4ad4d2250df Parents: b87eefa Author: Alexey Goncharuk <agoncha...@gridgain.com> Authored: Sun Mar 15 22:27:00 2015 -0700 Committer: Alexey Goncharuk <agoncha...@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} */
