Repository: ignite Updated Branches: refs/heads/ignite-gg-11133 7a3cb0c81 -> 383c7d813
enabled tests Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/383c7d81 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/383c7d81 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/383c7d81 Branch: refs/heads/ignite-gg-11133 Commit: 383c7d81388264ac870730607a735217fc2e6513 Parents: 7a3cb0c Author: sboikov <sboi...@apache.org> Authored: Tue Oct 9 14:58:38 2018 +0300 Committer: sboikov <sboi...@apache.org> Committed: Tue Oct 9 14:58:38 2018 +0300 ---------------------------------------------------------------------- ...eContinuousQueryConcurrentPartitionUpdateTest.java | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/383c7d81/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryConcurrentPartitionUpdateTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryConcurrentPartitionUpdateTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryConcurrentPartitionUpdateTest.java index 6c74f79..6c0db43 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryConcurrentPartitionUpdateTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryConcurrentPartitionUpdateTest.java @@ -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());
