ignite-1792: ContinuousProcessor should use ALWAYS_TRUE predicate instead of null
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/b5a30693 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/b5a30693 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/b5a30693 Branch: refs/heads/ignite-1753-1282 Commit: b5a30693498c17e5ecea04dd19c8608f54321076 Parents: e9aa4d1 Author: Andrey Gura <ag...@gridgain.com> Authored: Tue Oct 27 14:03:27 2015 +0300 Committer: Denis Magda <dma...@gridgain.com> Committed: Tue Oct 27 14:03:27 2015 +0300 ---------------------------------------------------------------------- .../cache/query/continuous/CacheContinuousQueryManager.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/b5a30693/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java index 6a151a5..c7bf091 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java @@ -419,10 +419,8 @@ public class CacheContinuousQueryManager extends GridCacheManagerAdapter { taskNameHash, skipPrimaryCheck); - IgnitePredicate<ClusterNode> pred = null; - - if (loc || cctx.config().getCacheMode() == CacheMode.LOCAL) - pred = F.nodeForNodeId(cctx.localNodeId()); + IgnitePredicate<ClusterNode> pred = (loc || cctx.config().getCacheMode() == CacheMode.LOCAL) ? + F.nodeForNodeId(cctx.localNodeId()) : F.<ClusterNode>alwaysTrue(); UUID id = cctx.kernalContext().continuous().startRoutine( hnd,