From aafa92d5660adddf60bc651543217a95e1f12b0c Mon Sep 17 00:00:00 2001 From: voipp Date: Thu, 14 Jun 2018 15:21:02 +0300 Subject: [PATCH] #rerun test 200 times --- .../IgniteCacheQuerySelfTestSuite4.java | 26 +++++++++++++------ 1 file changed, 18 insertions(+), 8 deletions(-) diff --git a/modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheQuerySelfTestSuite4.java b/modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheQuerySelfTestSuite4.java index 2aa3419764427..c9ad2ae71b9dd 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheQuerySelfTestSuite4.java +++ b/modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheQuerySelfTestSuite4.java @@ -38,14 +38,24 @@ public static TestSuite suite() throws Exception { TestSuite suite = new TestSuite("Ignite Cache Queries Test Suite 4"); // Continuous queries failover tests. - suite.addTestSuite(CacheContinuousQueryFailoverAtomicSelfTest.class); - suite.addTestSuite(CacheContinuousQueryFailoverAtomicReplicatedSelfTest.class); - suite.addTestSuite(CacheContinuousQueryFailoverTxSelfTest.class); - suite.addTestSuite(CacheContinuousQueryFailoverTxReplicatedSelfTest.class); - - suite.addTestSuite(CacheContinuousQueryAsyncFailoverAtomicSelfTest.class); - suite.addTestSuite(CacheContinuousQueryAsyncFailoverTxReplicatedSelfTest.class); - suite.addTestSuite(CacheContinuousQueryAsyncFailoverTxSelfTest.class); +// suite.addTestSuite(CacheContinuousQueryFailoverAtomicSelfTest.class); +// suite.addTestSuite(CacheContinuousQueryFailoverAtomicReplicatedSelfTest.class); +// suite.addTestSuite(CacheContinuousQueryFailoverTxSelfTest.class); +// suite.addTestSuite(CacheContinuousQueryFailoverTxReplicatedSelfTest.class); +// +// suite.addTestSuite(CacheContinuousQueryAsyncFailoverAtomicSelfTest.class); +// suite.addTestSuite(CacheContinuousQueryAsyncFailoverTxReplicatedSelfTest.class); +// suite.addTestSuite(CacheContinuousQueryAsyncFailoverTxSelfTest.class); +// +// CacheContinuousQueryFailoverAtomicSelfTest + + for (int i = 0; i < 200; i++) { + CacheContinuousQueryAsyncFailoverAtomicSelfTest test = new CacheContinuousQueryAsyncFailoverAtomicSelfTest(); + + test.setName("testMultiThreadedFailover"); + + suite.addTest(test); + } return suite; }