Enabled tests
@@ -246,14 +246,14 @@ public class CacheContinuousQueryConcurrentPartitionUpdateTest extends GridCommo
/**
* @throws Exception If failed.
*/
- public void _testConcurrentUpdatesAndQueryStartAtomicCacheGroup() throws Exception {
+ public void testConcurrentUpdatesAndQueryStartAtomicCacheGroup() throws Exception {
concurrentUpdatesAndQueryStart(ATOMIC, true);
}
/**
* @throws Exception If failed.
*/
- public void _testConcurrentUpdatesAndQueryStartTxCacheGroup() throws Exception {
+ public void testConcurrentUpdatesAndQueryStartTxCacheGroup() throws Exception {
concurrentUpdatesAndQueryStart(TRANSACTIONAL, true);
}
@@ -273,24 +273,24 @@ public class CacheContinuousQueryConcurrentPartitionUpdateTest extends GridCommo
if (cacheGrp) {
for (int i = 0; i < 3; i++) {
- CacheConfiguration ccfg = new CacheConfiguration(DEFAULT_CACHE_NAME + i);
+ CacheConfiguration<?, ?> ccfg = new CacheConfiguration<>(DEFAULT_CACHE_NAME + i);
ccfg.setGroupName("testGroup");
ccfg.setWriteSynchronizationMode(FULL_SYNC);
ccfg.setAtomicityMode(atomicityMode);
- IgniteCache cache = client.createCache(ccfg);
+ IgniteCache<?, ?> cache = client.createCache(ccfg);
caches.add(cache.getName());
}
}
else {
- CacheConfiguration ccfg = new CacheConfiguration(DEFAULT_CACHE_NAME);
+ CacheConfiguration<?, ?> ccfg = new CacheConfiguration<>(DEFAULT_CACHE_NAME);
ccfg.setWriteSynchronizationMode(FULL_SYNC);
ccfg.setAtomicityMode(atomicityMode);
- IgniteCache cache = client.createCache(ccfg);
+ IgniteCache<?, ?> cache = client.createCache(ccfg);
caches.add(cache.getName());
}
@@ -378,7 +378,7 @@ public class CacheContinuousQueryConcurrentPartitionUpdateTest extends GridCommo
return evtCnt.get() >= THREADS * UPDATES;
}
- }, 5000);
+ }, 30000);
assertEquals(THREADS * UPDATES, qry.get1().get());
