Repository: ignite Updated Branches: refs/heads/ignite-zk 4749d332c -> 93dd7ab79
zk Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/93dd7ab7 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/93dd7ab7 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/93dd7ab7 Branch: refs/heads/ignite-zk Commit: 93dd7ab79c6ed38c29a87ca7a676fbfcefd57273 Parents: 4749d33 Author: sboikov <sboi...@gridgain.com> Authored: Wed Nov 22 16:22:17 2017 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Wed Nov 22 16:22:17 2017 +0300 ---------------------------------------------------------------------- .../discovery/zk/internal/ZookeeperDiscoverySpiBasicTest.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/93dd7ab7/modules/zookeeper/src/test/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoverySpiBasicTest.java ---------------------------------------------------------------------- diff --git a/modules/zookeeper/src/test/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoverySpiBasicTest.java b/modules/zookeeper/src/test/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoverySpiBasicTest.java index c481b3d..0df9892 100644 --- a/modules/zookeeper/src/test/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoverySpiBasicTest.java +++ b/modules/zookeeper/src/test/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoverySpiBasicTest.java @@ -263,6 +263,8 @@ public class ZookeeperDiscoverySpiBasicTest extends GridCommonAbstractTest { stopGrid(1); + waitForTopology(3); + for (Ignite node : G.allGrids()) { assertEquals(1, node.cluster().forClients().nodes().size()); assertEquals(2, node.cluster().forServers().nodes().size()); @@ -270,6 +272,8 @@ public class ZookeeperDiscoverySpiBasicTest extends GridCommonAbstractTest { stopGrid(2); + waitForTopology(2); + for (Ignite node : G.allGrids()) { assertEquals(1, node.cluster().forClients().nodes().size()); assertEquals(1, node.cluster().forServers().nodes().size());
