ignite-5075
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/14719419 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/14719419 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/14719419 Branch: refs/heads/ignite-5075-pds Commit: 1471941953d17d3f8e7f86cd26fce8df139ed024 Parents: 4e51f6c Author: sboikov <[email protected]> Authored: Fri Jun 2 10:49:24 2017 +0300 Committer: sboikov <[email protected]> Committed: Fri Jun 2 10:49:24 2017 +0300 ---------------------------------------------------------------------- .../CacheContinuousQueryConcurrentPartitionUpdateTest.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/14719419/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 34cb777..6c74f79 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); } @@ -379,9 +379,7 @@ public class CacheContinuousQueryConcurrentPartitionUpdateTest extends GridCommo return evtCnt.get() >= THREADS * UPDATES; } }, 5000); - } - for (T2<AtomicInteger, QueryCursor> qry : qrys) { assertEquals(THREADS * UPDATES, qry.get1().get()); qry.get2().close();
