Repository: ignite Updated Branches: refs/heads/ignite-2604 0eb91541d -> 97245061c
IGNITE-2604 Fixed review notes. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/97245061 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/97245061 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/97245061 Branch: refs/heads/ignite-2604 Commit: 97245061ca56863b60c93497e01ce17a4b9850ff Parents: 0eb9154 Author: nikolay_tikhonov <[email protected]> Authored: Tue Feb 16 13:36:13 2016 +0300 Committer: nikolay_tikhonov <[email protected]> Committed: Tue Feb 16 13:36:13 2016 +0300 ---------------------------------------------------------------------- .../query/continuous/CacheContinuousQueryLostPartitionTest.java | 4 +++- .../apache/ignite/testsuites/IgniteCacheQuerySelfTestSuite.java | 4 ++-- 2 files changed, 5 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/97245061/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryLostPartitionTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryLostPartitionTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryLostPartitionTest.java index 30613a4..f4659dc 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryLostPartitionTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryLostPartitionTest.java @@ -138,7 +138,9 @@ public class CacheContinuousQueryLostPartitionTest extends GridCommonAbstractTes }, 2000L) : "Expected no create events, but got: " + lsnr2.createdCnt.get(); // node2 now becomes the primary for the key. - grid(0).close(); + stopGrid(0); + + awaitPartitionMapExchange(); cache2.put(key, "2"); http://git-wip-us.apache.org/repos/asf/ignite/blob/97245061/modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheQuerySelfTestSuite.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheQuerySelfTestSuite.java b/modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheQuerySelfTestSuite.java index 0e2d9e3..c67a8cf 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheQuerySelfTestSuite.java +++ b/modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheQuerySelfTestSuite.java @@ -73,7 +73,7 @@ import org.apache.ignite.internal.processors.cache.local.IgniteCacheLocalFieldsQ import org.apache.ignite.internal.processors.cache.local.IgniteCacheLocalQuerySelfTest; import org.apache.ignite.internal.processors.cache.query.GridCacheSwapScanQuerySelfTest; import org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousBatchAckTest; -import org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousCacheFilterBatchAckTest; +import org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousBatchForceServerModeAckTest; import org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryFailoverAtomicPrimaryWriteOrderOffheapTieredTest; import org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryFailoverAtomicPrimaryWriteOrderSelfTest; import org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryFailoverAtomicReplicatedSelfTest; @@ -217,7 +217,7 @@ public class IgniteCacheQuerySelfTestSuite extends TestSuite { suite.addTestSuite(CacheContinuousQueryFailoverTxOffheapTieredTest.class); suite.addTestSuite(CacheContinuousQueryRandomOperationsTest.class); suite.addTestSuite(CacheContinuousBatchAckTest.class); - suite.addTestSuite(CacheContinuousCacheFilterBatchAckTest.class); + suite.addTestSuite(CacheContinuousBatchForceServerModeAckTest.class); // Reduce fields queries. suite.addTestSuite(GridCacheReduceFieldsQueryLocalSelfTest.class);
