ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [02/12] incubator-ignite git commit: Ignite-65 fox for GridCacheDataStructuresSelfTestSuite
Date Tue, 27 Jan 2015 09:28:50 GMT
Ignite-65 fox for GridCacheDataStructuresSelfTestSuite


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

Branch: refs/heads/sprint-1
Commit: f90b641629a4e54b073683b10fa294f43a4f6e0d
Parents: 16e5804
Author: avinogradov <avinogradov@gridgain.com>
Authored: Fri Jan 23 14:35:22 2015 +0300
Committer: avinogradov <avinogradov@gridgain.com>
Committed: Fri Jan 23 14:35:22 2015 +0300

----------------------------------------------------------------------
 .../query/continuous/GridCacheContinuousQueryManager.java | 10 ----------
 1 file changed, 10 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f90b6416/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/query/continuous/GridCacheContinuousQueryManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/query/continuous/GridCacheContinuousQueryManager.java
b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/query/continuous/GridCacheContinuousQueryManager.java
index 6e1eac3..924b8a4 100644
--- a/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/query/continuous/GridCacheContinuousQueryManager.java
+++ b/modules/core/src/main/java/org/gridgain/grid/kernal/processors/cache/query/continuous/GridCacheContinuousQueryManager.java
@@ -76,16 +76,6 @@ public class GridCacheContinuousQueryManager<K, V> extends GridCacheManagerAdapt
     /** {@inheritDoc} */
     @SuppressWarnings("unchecked")
     @Override protected void onKernalStart0() throws IgniteCheckedException {
-        if (intLsnrCnt.get() > 0 || lsnrCnt.get() > 0) {
-            Collection<ClusterNode> nodes = cctx.discovery().cacheNodes(cctx.name(),
-1);
-
-            for (ClusterNode n : nodes) {
-                if (!n.version().greaterThanEqual(6, 2, 0))
-                    throw new IgniteCheckedException("Rolling update is not supported for
continuous queries " +
-                        "for versions below 6.2.0");
-            }
-        }
-
         Iterable<CacheEntryListenerConfiguration<K, V>> lsnrCfgs = cctx.config().getCacheEntryListenerConfigurations();
 
         if (lsnrCfgs != null) {


Mime
View raw message