ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ntikho...@apache.org
Subject ignite git commit: Debug test.
Date Tue, 17 May 2016 14:44:06 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-test [created] 08b2a7220


Debug test.


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

Branch: refs/heads/ignite-test
Commit: 08b2a72205bfeaeba1122e0250cadfc904967212
Parents: a606f59
Author: nikolay_tikhonov <ntikhonov@gridgain.com>
Authored: Tue May 17 17:43:36 2016 +0300
Committer: nikolay_tikhonov <ntikhonov@gridgain.com>
Committed: Tue May 17 17:43:36 2016 +0300

----------------------------------------------------------------------
 ...acheContinuousQueryRandomOperationsTest.java | 1258 +++++++++---------
 .../IgniteCacheQuerySelfTestSuite3.java         |   79 +-
 2 files changed, 673 insertions(+), 664 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/08b2a722/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryRandomOperationsTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryRandomOperationsTest.java
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryRandomOperationsTest.java
index a6c33bb..75ff9f3 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryRandomOperationsTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryRandomOperationsTest.java
@@ -143,337 +143,337 @@ public class CacheContinuousQueryRandomOperationsTest extends GridCommonAbstract
 
         super.afterTestsStopped();
     }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testFilterAndFactoryProvided() throws Exception {
-        final CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            ATOMIC,
-            ONHEAP_TIERED,
-            false);
-
-        grid(0).createCache(ccfg);
-
-        try {
-            final ContinuousQuery qry = new ContinuousQuery();
-
-            qry.setRemoteFilterFactory(new Factory<CacheEntryEventFilter>() {
-                @Override public CacheEntryEventFilter create() {
-                    return null;
-                }
-            });
-
-            qry.setRemoteFilter(new CacheEntryEventSerializableFilter() {
-                @Override public boolean evaluate(CacheEntryEvent event) throws CacheEntryListenerException
{
-                    return false;
-                }
-            });
-
-            qry.setLocalListener(new CacheEntryUpdatedListener() {
-                @Override public void onUpdated(Iterable iterable) throws CacheEntryListenerException
{
-                    // No-op.
-                }
-            });
-
-            GridTestUtils.assertThrows(log, new Callable<Object>() {
-                @Override public Object call() throws Exception {
-                    return grid(0).cache(ccfg.getName()).query(qry);
-                }
-            }, IgniteException.class, null);
-
-        }
-        finally {
-            grid(0).destroyCache(ccfg.getName());
-        }
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testAtomicClient() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            ATOMIC,
-            ONHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, CLIENT);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testAtomic() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            ATOMIC,
-            ONHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, SERVER);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testAtomicAllNodes() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            ATOMIC,
-            ONHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, ALL);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testAtomicReplicated() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
-            0,
-            ATOMIC,
-            ONHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, SERVER);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testAtomicReplicatedAllNodes() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
-            0,
-            ATOMIC,
-            ONHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, ALL);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testAtomicReplicatedClient() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
-            0,
-            ATOMIC,
-            ONHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, CLIENT);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testAtomicOffheapValues() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            ATOMIC,
-            OFFHEAP_VALUES,
-            false);
-
-        doTestContinuousQuery(ccfg, SERVER);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testAtomicOffheapValuesAllNodes() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            ATOMIC,
-            OFFHEAP_VALUES,
-            false);
-
-        doTestContinuousQuery(ccfg, ALL);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testAtomicOffheapValuesClient() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            ATOMIC,
-            OFFHEAP_VALUES,
-            false);
-
-        doTestContinuousQuery(ccfg, CLIENT);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testAtomicOffheapTiered() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            ATOMIC,
-            OFFHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, SERVER);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testAtomicOffheapTieredAllNodes() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            ATOMIC,
-            OFFHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, ALL);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testAtomicOffheapTieredClient() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            ATOMIC,
-            OFFHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, CLIENT);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testAtomicNoBackups() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            0,
-            ATOMIC,
-            ONHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, SERVER);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testAtomicNoBackupsAllNodes() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            0,
-            ATOMIC,
-            ONHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, ALL);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testAtomicNoBackupsClient() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            0,
-            ATOMIC,
-            ONHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, CLIENT);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testTx() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            TRANSACTIONAL,
-            ONHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, SERVER);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testTxAllNodes() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            TRANSACTIONAL,
-            ONHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, ALL);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testTxExplicit() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            TRANSACTIONAL,
-            ONHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, SERVER);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testDoubleRemoveAtomicWithoutBackup() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            0,
-            ATOMIC,
-            ONHEAP_TIERED,
-            false);
-
-        doTestNotModifyOperation(ccfg);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testDoubleRemoveAtomicWithoutBackupWithStore() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            0,
-            ATOMIC,
-            ONHEAP_TIERED,
-            false);
-
-        doTestNotModifyOperation(ccfg);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testDoubleRemoveAtomic() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            ATOMIC,
-            ONHEAP_TIERED,
-            false);
-
-        doTestNotModifyOperation(ccfg);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testDoubleRemoveAtomicWithStore() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            ATOMIC,
-            ONHEAP_TIERED,
-            true);
-
-        doTestNotModifyOperation(ccfg);
-    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testFilterAndFactoryProvided() throws Exception {
+//        final CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            ATOMIC,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        grid(0).createCache(ccfg);
+//
+//        try {
+//            final ContinuousQuery qry = new ContinuousQuery();
+//
+//            qry.setRemoteFilterFactory(new Factory<CacheEntryEventFilter>() {
+//                @Override public CacheEntryEventFilter create() {
+//                    return null;
+//                }
+//            });
+//
+//            qry.setRemoteFilter(new CacheEntryEventSerializableFilter() {
+//                @Override public boolean evaluate(CacheEntryEvent event) throws CacheEntryListenerException
{
+//                    return false;
+//                }
+//            });
+//
+//            qry.setLocalListener(new CacheEntryUpdatedListener() {
+//                @Override public void onUpdated(Iterable iterable) throws CacheEntryListenerException
{
+//                    // No-op.
+//                }
+//            });
+//
+//            GridTestUtils.assertThrows(log, new Callable<Object>() {
+//                @Override public Object call() throws Exception {
+//                    return grid(0).cache(ccfg.getName()).query(qry);
+//                }
+//            }, IgniteException.class, null);
+//
+//        }
+//        finally {
+//            grid(0).destroyCache(ccfg.getName());
+//        }
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testAtomicClient() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            ATOMIC,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, CLIENT);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testAtomic() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            ATOMIC,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, SERVER);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testAtomicAllNodes() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            ATOMIC,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, ALL);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testAtomicReplicated() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
+//            0,
+//            ATOMIC,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, SERVER);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testAtomicReplicatedAllNodes() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
+//            0,
+//            ATOMIC,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, ALL);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testAtomicReplicatedClient() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
+//            0,
+//            ATOMIC,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, CLIENT);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testAtomicOffheapValues() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            ATOMIC,
+//            OFFHEAP_VALUES,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, SERVER);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testAtomicOffheapValuesAllNodes() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            ATOMIC,
+//            OFFHEAP_VALUES,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, ALL);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testAtomicOffheapValuesClient() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            ATOMIC,
+//            OFFHEAP_VALUES,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, CLIENT);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testAtomicOffheapTiered() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            ATOMIC,
+//            OFFHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, SERVER);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testAtomicOffheapTieredAllNodes() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            ATOMIC,
+//            OFFHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, ALL);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testAtomicOffheapTieredClient() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            ATOMIC,
+//            OFFHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, CLIENT);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testAtomicNoBackups() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            0,
+//            ATOMIC,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, SERVER);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testAtomicNoBackupsAllNodes() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            0,
+//            ATOMIC,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, ALL);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testAtomicNoBackupsClient() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            0,
+//            ATOMIC,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, CLIENT);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testTx() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            TRANSACTIONAL,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, SERVER);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testTxAllNodes() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            TRANSACTIONAL,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, ALL);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testTxExplicit() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            TRANSACTIONAL,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, SERVER);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testDoubleRemoveAtomicWithoutBackup() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            0,
+//            ATOMIC,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestNotModifyOperation(ccfg);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testDoubleRemoveAtomicWithoutBackupWithStore() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            0,
+//            ATOMIC,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestNotModifyOperation(ccfg);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testDoubleRemoveAtomic() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            ATOMIC,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestNotModifyOperation(ccfg);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testDoubleRemoveAtomicWithStore() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            ATOMIC,
+//            ONHEAP_TIERED,
+//            true);
+//
+//        doTestNotModifyOperation(ccfg);
+//    }
 
     /**
      * @throws Exception If failed.
@@ -487,97 +487,97 @@ public class CacheContinuousQueryRandomOperationsTest extends GridCommonAbstract
 
         doTestNotModifyOperation(ccfg);
     }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testDoubleRemoveAtomicOffheapWithStore() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            0,
-            ATOMIC,
-            OFFHEAP_TIERED,
-            true);
-
-        doTestNotModifyOperation(ccfg);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testDoubleRemoveTx() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            TRANSACTIONAL,
-            ONHEAP_TIERED,
-            false);
-
-        doTestNotModifyOperation(ccfg);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testDoubleRemoveTxWithStore() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            TRANSACTIONAL,
-            ONHEAP_TIERED,
-            false);
-
-        doTestNotModifyOperation(ccfg);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testDoubleRemoveReplicatedTx() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
-            0,
-            TRANSACTIONAL,
-            ONHEAP_TIERED,
-            false);
-
-        doTestNotModifyOperation(ccfg);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testDoubleRemoveReplicatedTxWithStore() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
-            0,
-            TRANSACTIONAL,
-            ONHEAP_TIERED,
-            false);
-
-        doTestNotModifyOperation(ccfg);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testDoubleRemoveReplicatedAtomic() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
-            0,
-            ATOMIC,
-            ONHEAP_TIERED,
-            false);
-
-        doTestNotModifyOperation(ccfg);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testDoubleRemoveReplicatedAtomicWithStore() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
-            0,
-            ATOMIC,
-            ONHEAP_TIERED,
-            true);
-
-        doTestNotModifyOperation(ccfg);
-    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testDoubleRemoveAtomicOffheapWithStore() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            0,
+//            ATOMIC,
+//            OFFHEAP_TIERED,
+//            true);
+//
+//        doTestNotModifyOperation(ccfg);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testDoubleRemoveTx() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            TRANSACTIONAL,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestNotModifyOperation(ccfg);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testDoubleRemoveTxWithStore() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            TRANSACTIONAL,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestNotModifyOperation(ccfg);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testDoubleRemoveReplicatedTx() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
+//            0,
+//            TRANSACTIONAL,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestNotModifyOperation(ccfg);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testDoubleRemoveReplicatedTxWithStore() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
+//            0,
+//            TRANSACTIONAL,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestNotModifyOperation(ccfg);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testDoubleRemoveReplicatedAtomic() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
+//            0,
+//            ATOMIC,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestNotModifyOperation(ccfg);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testDoubleRemoveReplicatedAtomicWithStore() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
+//            0,
+//            ATOMIC,
+//            ONHEAP_TIERED,
+//            true);
+//
+//        doTestNotModifyOperation(ccfg);
+//    }
 
     /**
      * @throws Exception If failed.
@@ -848,213 +848,213 @@ public class CacheContinuousQueryRandomOperationsTest extends GridCommonAbstract
         assertEquals(event.getOldValue(), oldVal);
     }
 
-    /**
-     * @throws Exception If failed.
-     */
-    public void testTxClient() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            TRANSACTIONAL,
-            ONHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, CLIENT);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testTxClientExplicit() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            TRANSACTIONAL,
-            ONHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, CLIENT);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testTxReplicated() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
-            0,
-            TRANSACTIONAL,
-            ONHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, SERVER);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testTxReplicatedClient() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
-            0,
-            TRANSACTIONAL,
-            ONHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, CLIENT);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testTxOffheapValues() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            TRANSACTIONAL,
-            OFFHEAP_VALUES,
-            false);
-
-        doTestContinuousQuery(ccfg, SERVER);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testTxOffheapValuesAllNodes() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            TRANSACTIONAL,
-            OFFHEAP_VALUES,
-            false);
-
-        doTestContinuousQuery(ccfg, ALL);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testTxOffheapValuesExplicit() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            TRANSACTIONAL,
-            OFFHEAP_VALUES,
-            false);
-
-        doTestContinuousQuery(ccfg, SERVER);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testTxOffheapValuesClient() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            TRANSACTIONAL,
-            OFFHEAP_VALUES,
-            false);
-
-        doTestContinuousQuery(ccfg, CLIENT);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testTxOffheapTiered() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            TRANSACTIONAL,
-            OFFHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, SERVER);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testTxOffheapTieredAllNodes() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            TRANSACTIONAL,
-            OFFHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, ALL);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testTxOffheapTieredClient() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            TRANSACTIONAL,
-            OFFHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, CLIENT);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testTxOffheapTieredClientExplicit() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            1,
-            TRANSACTIONAL,
-            OFFHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, CLIENT);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testTxNoBackups() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            0,
-            TRANSACTIONAL,
-            ONHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, SERVER);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testTxNoBackupsAllNodes() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            0,
-            TRANSACTIONAL,
-            ONHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, ALL);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testTxNoBackupsExplicit() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            0,
-            TRANSACTIONAL,
-            ONHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, SERVER);
-    }
-
-    /**
-     * @throws Exception If failed.
-     */
-    public void testTxNoBackupsClient() throws Exception {
-        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
-            0,
-            TRANSACTIONAL,
-            ONHEAP_TIERED,
-            false);
-
-        doTestContinuousQuery(ccfg, CLIENT);
-    }
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testTxClient() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            TRANSACTIONAL,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, CLIENT);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testTxClientExplicit() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            TRANSACTIONAL,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, CLIENT);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testTxReplicated() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
+//            0,
+//            TRANSACTIONAL,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, SERVER);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testTxReplicatedClient() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(REPLICATED,
+//            0,
+//            TRANSACTIONAL,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, CLIENT);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testTxOffheapValues() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            TRANSACTIONAL,
+//            OFFHEAP_VALUES,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, SERVER);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testTxOffheapValuesAllNodes() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            TRANSACTIONAL,
+//            OFFHEAP_VALUES,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, ALL);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testTxOffheapValuesExplicit() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            TRANSACTIONAL,
+//            OFFHEAP_VALUES,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, SERVER);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testTxOffheapValuesClient() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            TRANSACTIONAL,
+//            OFFHEAP_VALUES,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, CLIENT);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testTxOffheapTiered() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            TRANSACTIONAL,
+//            OFFHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, SERVER);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testTxOffheapTieredAllNodes() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            TRANSACTIONAL,
+//            OFFHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, ALL);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testTxOffheapTieredClient() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            TRANSACTIONAL,
+//            OFFHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, CLIENT);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testTxOffheapTieredClientExplicit() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            1,
+//            TRANSACTIONAL,
+//            OFFHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, CLIENT);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testTxNoBackups() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            0,
+//            TRANSACTIONAL,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, SERVER);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testTxNoBackupsAllNodes() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            0,
+//            TRANSACTIONAL,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, ALL);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testTxNoBackupsExplicit() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            0,
+//            TRANSACTIONAL,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, SERVER);
+//    }
+//
+//    /**
+//     * @throws Exception If failed.
+//     */
+//    public void testTxNoBackupsClient() throws Exception {
+//        CacheConfiguration<Object, Object> ccfg = cacheConfiguration(PARTITIONED,
+//            0,
+//            TRANSACTIONAL,
+//            ONHEAP_TIERED,
+//            false);
+//
+//        doTestContinuousQuery(ccfg, CLIENT);
+//    }
 
     /**
      * @param ccfg Cache configuration.

http://git-wip-us.apache.org/repos/asf/ignite/blob/08b2a722/modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheQuerySelfTestSuite3.java
----------------------------------------------------------------------
diff --git a/modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheQuerySelfTestSuite3.java
b/modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheQuerySelfTestSuite3.java
index e0e81b7..92b4a8d 100644
--- a/modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheQuerySelfTestSuite3.java
+++ b/modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheQuerySelfTestSuite3.java
@@ -67,42 +67,51 @@ public class IgniteCacheQuerySelfTestSuite3 extends TestSuite {
         TestSuite suite = new TestSuite("Ignite Cache Queries Test Suite 3");
 
         // Continuous queries.
-        suite.addTestSuite(GridCacheContinuousQueryLocalSelfTest.class);
-        suite.addTestSuite(GridCacheContinuousQueryLocalAtomicSelfTest.class);
-        suite.addTestSuite(GridCacheContinuousQueryReplicatedSelfTest.class);
-        suite.addTestSuite(GridCacheContinuousQueryReplicatedAtomicSelfTest.class);
-        suite.addTestSuite(GridCacheContinuousQueryReplicatedP2PDisabledSelfTest.class);
-        suite.addTestSuite(GridCacheContinuousQueryPartitionedSelfTest.class);
-        suite.addTestSuite(GridCacheContinuousQueryPartitionedOnlySelfTest.class);
-        suite.addTestSuite(GridCacheContinuousQueryPartitionedP2PDisabledSelfTest.class);
-        suite.addTestSuite(GridCacheContinuousQueryTxSelfTest.class);
-        suite.addTestSuite(GridCacheContinuousQueryTxOffheapTieredTest.class);
-        suite.addTestSuite(GridCacheContinuousQueryTxOffheapValuesTest.class);
-        suite.addTestSuite(GridCacheContinuousQueryAtomicSelfTest.class);
-        suite.addTestSuite(GridCacheContinuousQueryAtomicNearEnabledSelfTest.class);
-        suite.addTestSuite(GridCacheContinuousQueryAtomicP2PDisabledSelfTest.class);
-        suite.addTestSuite(GridCacheContinuousQueryAtomicOffheapTieredTest.class);
-        suite.addTestSuite(GridCacheContinuousQueryAtomicOffheapValuesTest.class);
-        suite.addTestSuite(GridCacheContinuousQueryReplicatedTxOneNodeTest.class);
-        suite.addTestSuite(GridCacheContinuousQueryReplicatedAtomicOneNodeTest.class);
-        suite.addTestSuite(GridCacheContinuousQueryPartitionTxOneNodeTest.class);
-        suite.addTestSuite(GridCacheContinuousQueryPartitionAtomicOneNodeTest.class);
-        suite.addTestSuite(IgniteCacheContinuousQueryClientTest.class);
-        suite.addTestSuite(IgniteCacheContinuousQueryClientReconnectTest.class);
-        suite.addTestSuite(IgniteCacheContinuousQueryClientTxReconnectTest.class);
+//        suite.addTestSuite(GridCacheContinuousQueryLocalSelfTest.class);
+//        suite.addTestSuite(GridCacheContinuousQueryLocalAtomicSelfTest.class);
+//        suite.addTestSuite(GridCacheContinuousQueryReplicatedSelfTest.class);
+//        suite.addTestSuite(GridCacheContinuousQueryReplicatedAtomicSelfTest.class);
+//        suite.addTestSuite(GridCacheContinuousQueryReplicatedP2PDisabledSelfTest.class);
+//        suite.addTestSuite(GridCacheContinuousQueryPartitionedSelfTest.class);
+//        suite.addTestSuite(GridCacheContinuousQueryPartitionedOnlySelfTest.class);
+//        suite.addTestSuite(GridCacheContinuousQueryPartitionedP2PDisabledSelfTest.class);
+//        suite.addTestSuite(GridCacheContinuousQueryTxSelfTest.class);
+//        suite.addTestSuite(GridCacheContinuousQueryTxOffheapTieredTest.class);
+//        suite.addTestSuite(GridCacheContinuousQueryTxOffheapValuesTest.class);
+//        suite.addTestSuite(GridCacheContinuousQueryAtomicSelfTest.class);
+//        suite.addTestSuite(GridCacheContinuousQueryAtomicNearEnabledSelfTest.class);
+//        suite.addTestSuite(GridCacheContinuousQueryAtomicP2PDisabledSelfTest.class);
+//        suite.addTestSuite(GridCacheContinuousQueryAtomicOffheapTieredTest.class);
+//        suite.addTestSuite(GridCacheContinuousQueryAtomicOffheapValuesTest.class);
+//        suite.addTestSuite(GridCacheContinuousQueryReplicatedTxOneNodeTest.class);
+//        suite.addTestSuite(GridCacheContinuousQueryReplicatedAtomicOneNodeTest.class);
+//        suite.addTestSuite(GridCacheContinuousQueryPartitionTxOneNodeTest.class);
+//        suite.addTestSuite(GridCacheContinuousQueryPartitionAtomicOneNodeTest.class);
+//        suite.addTestSuite(IgniteCacheContinuousQueryClientTest.class);
+//        suite.addTestSuite(IgniteCacheContinuousQueryClientReconnectTest.class);
+//        suite.addTestSuite(IgniteCacheContinuousQueryClientTxReconnectTest.class);
         suite.addTestSuite(CacheContinuousQueryRandomOperationsTest.class);
-        suite.addTestSuite(CacheContinuousQueryRandomOperationsTwoNodesTest.class);
-        suite.addTestSuite(GridCacheContinuousQueryConcurrentTest.class);
-        suite.addTestSuite(CacheContinuousQueryAsyncFilterListenerTest.class);
-        suite.addTestSuite(CacheContinuousQueryFactoryFilterRandomOperationTest.class);
-        suite.addTestSuite(CacheContinuousQueryFactoryAsyncFilterRandomOperationTest.class);
-        suite.addTestSuite(CacheContinuousQueryOrderingEventTest.class);
-        suite.addTestSuite(CacheContinuousQueryOperationFromCallbackTest.class);
-        suite.addTestSuite(CacheContinuousQueryOperationP2PTest.class);
-        suite.addTestSuite(CacheContinuousBatchAckTest.class);
-        suite.addTestSuite(CacheContinuousBatchForceServerModeAckTest.class);
-        suite.addTestSuite(CacheContinuousQueryExecuteInPrimaryTest.class);
-        suite.addTestSuite(CacheContinuousQueryLostPartitionTest.class);
+        suite.addTestSuite(CacheContinuousQueryRandomOperationsTest.class);
+        suite.addTestSuite(CacheContinuousQueryRandomOperationsTest.class);
+        suite.addTestSuite(CacheContinuousQueryRandomOperationsTest.class);
+        suite.addTestSuite(CacheContinuousQueryRandomOperationsTest.class);
+        suite.addTestSuite(CacheContinuousQueryRandomOperationsTest.class);
+        suite.addTestSuite(CacheContinuousQueryRandomOperationsTest.class);
+        suite.addTestSuite(CacheContinuousQueryRandomOperationsTest.class);
+        suite.addTestSuite(CacheContinuousQueryRandomOperationsTest.class);
+        suite.addTestSuite(CacheContinuousQueryRandomOperationsTest.class);
+//        suite.addTestSuite(CacheContinuousQueryRandomOperationsTwoNodesTest.class);
+//        suite.addTestSuite(GridCacheContinuousQueryConcurrentTest.class);
+//        suite.addTestSuite(CacheContinuousQueryAsyncFilterListenerTest.class);
+//        suite.addTestSuite(CacheContinuousQueryFactoryFilterRandomOperationTest.class);
+//        suite.addTestSuite(CacheContinuousQueryFactoryAsyncFilterRandomOperationTest.class);
+//        suite.addTestSuite(CacheContinuousQueryOrderingEventTest.class);
+//        suite.addTestSuite(CacheContinuousQueryOperationFromCallbackTest.class);
+//        suite.addTestSuite(CacheContinuousQueryOperationP2PTest.class);
+//        suite.addTestSuite(CacheContinuousBatchAckTest.class);
+//        suite.addTestSuite(CacheContinuousBatchForceServerModeAckTest.class);
+//        suite.addTestSuite(CacheContinuousQueryExecuteInPrimaryTest.class);
+//        suite.addTestSuite(CacheContinuousQueryLostPartitionTest.class);
 
         return suite;
     }


Mime
View raw message