Repository: ignite Updated Branches: refs/heads/ignite-426-2-reb f5c11c99b -> 1717183f2
IGNITE-426 Fixed tests. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/1717183f Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/1717183f Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/1717183f Branch: refs/heads/ignite-426-2-reb Commit: 1717183f2cdcc7684c61d2d3a1f01e31bc224014 Parents: f5c11c9 Author: Tikhonov Nikolay <[email protected]> Authored: Tue Nov 3 17:46:26 2015 +0300 Committer: Tikhonov Nikolay <[email protected]> Committed: Tue Nov 3 17:46:26 2015 +0300 ---------------------------------------------------------------------- .../CacheContinuousQueryFailoverAbstractSelfTest.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/1717183f/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractSelfTest.java index edf257e..f866424 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryFailoverAbstractSelfTest.java @@ -1252,7 +1252,7 @@ public abstract class CacheContinuousQueryFailoverAbstractSelfTest extends GridC * @throws Exception If failed. */ public void testFailover() throws Exception { - this.backups = 2; + this.backups = 3; final int SRV_NODES = 4; @@ -1289,12 +1289,18 @@ public abstract class CacheContinuousQueryFailoverAbstractSelfTest extends GridC startGrid(idx); + awaitPartitionMapExchange(); + Thread.sleep(200); log.info("Stop node: " + idx); try { stopGrid(idx); + + awaitPartitionMapExchange(); + + Thread.sleep(200); } catch (Exception e) { log.warning("Failed to stop nodes.", e);
