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/ignite-49 Commit: f90b641629a4e54b073683b10fa294f43a4f6e0d Parents: 16e5804 Author: avinogradov <avinogra...@gridgain.com> Authored: Fri Jan 23 14:35:22 2015 +0300 Committer: avinogradov <avinogra...@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) {
