minor
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/d24c2da3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/d24c2da3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/d24c2da3 Branch: refs/heads/ignite-630 Commit: d24c2da35ac300484566bf2fe40d2664e4942686 Parents: 05672fe Author: Yakov Zhdanov <yzhda...@gridgain.com> Authored: Mon Jul 20 11:53:41 2015 +0300 Committer: Yakov Zhdanov <yzhda...@gridgain.com> Committed: Mon Jul 20 11:53:41 2015 +0300 ---------------------------------------------------------------------- .../apache/ignite/internal/processors/cache/IgniteCacheProxy.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/d24c2da3/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 0b2eba0..e532778 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 @@ -556,7 +556,7 @@ public class IgniteCacheProxy<K, V> extends AsyncSupportAdapter<IgniteCache<K, V if (isReplicatedDataNode() || ctx.isLocal() || qry.isLocal()) return (QueryCursor<R>)new QueryCursorImpl<>(new Iterable<Cache.Entry<K, V>>() { @Override public Iterator<Cache.Entry<K, V>> iterator() { - return ctx.kernalContext().query().<K, V>queryLocal(ctx, p); + return ctx.kernalContext().query().queryLocal(ctx, p); } });
