ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ntikho...@apache.org
Subject ignite git commit: IGNITE-426 Fixed tests.
Date Tue, 03 Nov 2015 14:42:58 GMT
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 <tikhonovnicolay@gmail.com>
Authored: Tue Nov 3 17:46:26 2015 +0300
Committer: Tikhonov Nikolay <tikhonovnicolay@gmail.com>
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);


Mime
View raw message