Repository: ignite Updated Branches: refs/heads/ignite-zk 4e8516d85 -> 09ab8649d
zk Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/c2ed250d Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/c2ed250d Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/c2ed250d Branch: refs/heads/ignite-zk Commit: c2ed250d6e66720ca4e4080cbd11c38b1fc0178a Parents: 3c311a3 Author: sboikov <sboi...@gridgain.com> Authored: Tue Dec 26 14:21:08 2017 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Tue Dec 26 14:21:08 2017 +0300 ---------------------------------------------------------------------- .../zk/internal/ZookeeperDiscoverySpiBasicTest.java | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/c2ed250d/modules/core/src/test/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoverySpiBasicTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoverySpiBasicTest.java b/modules/core/src/test/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoverySpiBasicTest.java index e492860..c3c22be 100644 --- a/modules/core/src/test/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoverySpiBasicTest.java +++ b/modules/core/src/test/java/org/apache/ignite/spi/discovery/zk/internal/ZookeeperDiscoverySpiBasicTest.java @@ -1815,7 +1815,13 @@ public class ZookeeperDiscoverySpiBasicTest extends GridCommonAbstractTest { public void testLargeUserAttribute3() throws Exception { ThreadLocalRandom rnd = ThreadLocalRandom.current(); + long stopTime = System.currentTimeMillis() + 60_000; + + int nodes = 0; + for (int i = 0; i < 25; i++) { + info("Iteration: " + i); + if (rnd.nextBoolean()) initLargeAttribute(); else @@ -1824,9 +1830,14 @@ public class ZookeeperDiscoverySpiBasicTest extends GridCommonAbstractTest { clientMode(i > 5); startGrid(i); + + nodes++; + + if (System.currentTimeMillis() >= stopTime) + break; } - waitForTopology(25); + waitForTopology(nodes); } /**
