ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ntikho...@apache.org
Subject ignite git commit: IGNITE-1186 minor fix.
Date Tue, 01 Mar 2016 17:09:45 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-1186 ca200fc1b -> 0e6b0b75b


IGNITE-1186 minor fix.


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

Branch: refs/heads/ignite-1186
Commit: 0e6b0b75bc77dbdf33bb389b35c527145a73501c
Parents: ca200fc
Author: nikolay_tikhonov <ntikhonov@gridgain.com>
Authored: Tue Mar 1 20:09:45 2016 +0300
Committer: nikolay_tikhonov <ntikhonov@gridgain.com>
Committed: Tue Mar 1 20:09:45 2016 +0300

----------------------------------------------------------------------
 .../cache/query/continuous/CacheContinuousQueryManager.java        | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/0e6b0b75/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 50253fa..353043f 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
@@ -637,7 +637,7 @@ public class CacheContinuousQueryManager extends GridCacheManagerAdapter
{
         hnd.notifyExisting(notifyExisting);
         hnd.internal(internal);
         hnd.keepBinary(keepBinary);
-        hnd.localCache(loc);
+        hnd.localCache(cctx.isLocal());
 
         IgnitePredicate<ClusterNode> pred = (loc || cctx.config().getCacheMode() ==
CacheMode.LOCAL) ?
             F.nodeForNodeId(cctx.localNodeId()) : F.<ClusterNode>alwaysTrue();


Mime
View raw message