Repository: incubator-ignite Updated Branches: refs/heads/ignite-45 77ca91c1c -> 01bc98478
IGNITE-543 - Continuous query fix Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/01bc9847 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/01bc9847 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/01bc9847 Branch: refs/heads/ignite-45 Commit: 01bc9847814f2854889fb2b4f9b87f25e83e2a2d Parents: 77ca91c Author: Valentin Kulichenko <vkuliche...@gridgain.com> Authored: Fri Mar 20 22:55:15 2015 -0700 Committer: Valentin Kulichenko <vkuliche...@gridgain.com> Committed: Fri Mar 20 22:55:15 2015 -0700 ---------------------------------------------------------------------- .../apache/ignite/internal/processors/cache/IgniteCacheProxy.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/01bc9847/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 8deb256..ea5761a 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 @@ -387,7 +387,8 @@ public class IgniteCacheProxy<K, V> extends AsyncSupportAdapter<IgniteCache<K, V qry.isAutoUnsubscribe(), loc ? ctx.grid().cluster().forLocal() : null); - final QueryCursor<Cache.Entry<K, V>> cur = query(qry.getInitialQuery()); + final QueryCursor<Cache.Entry<K, V>> cur = + qry.getInitialQuery() != null ? query(qry.getInitialQuery()) : null; return new QueryCursor<Cache.Entry<K, V>>() { @Override public Iterator<Cache.Entry<K, V>> iterator() {
