You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2018/10/09 21:01:27 UTC
ignite git commit: Enabled tests
Repository: ignite
Updated Branches:
refs/heads/master c7d6f110f -> 592fd6bb9
Enabled tests
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/592fd6bb
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/592fd6bb
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/592fd6bb
Branch: refs/heads/master
Commit: 592fd6bb98947fca49df4af00d01235e21413e53
Parents: c7d6f11
Author: sboikov <sb...@apache.org>
Authored: Tue Oct 9 23:59:33 2018 +0300
Committer: sboikov <sb...@apache.org>
Committed: Tue Oct 9 23:59:33 2018 +0300
----------------------------------------------------------------------
...eContinuousQueryConcurrentPartitionUpdateTest.java | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/592fd6bb/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());