Repository: ignite Updated Branches: refs/heads/ignite-zk 364d68574 -> 307852dcd
zk Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/307852dc Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/307852dc Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/307852dc Branch: refs/heads/ignite-zk Commit: 307852dcd8a839d569498a2cef7a66544d4349db Parents: 364d685 Author: sboikov <sboi...@gridgain.com> Authored: Fri Jan 12 16:29:49 2018 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Fri Jan 12 16:29:49 2018 +0300 ---------------------------------------------------------------------- .../processors/continuous/GridEventConsumeSelfTest.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/307852dc/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java index 21bfdd0..f768566 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/continuous/GridEventConsumeSelfTest.java @@ -1153,9 +1153,11 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest { final Random rnd = new Random(); + final int consumeCnt = tcpDiscovery() ? CONSUME_CNT : CONSUME_CNT / 2; + IgniteInternalFuture<?> starterFut = multithreadedAsync(new Callable<Object>() { @Override public Object call() throws Exception { - for (int i = 0; i < CONSUME_CNT; i++) { + for (int i = 0; i < consumeCnt; i++) { int idx = rnd.nextInt(GRID_CNT); try { @@ -1165,7 +1167,7 @@ public class GridEventConsumeSelfTest extends GridCommonAbstractTest { @Override public boolean apply(UUID uuid, Event evt) { return true; } - }, null, EVT_JOB_STARTED).get(10_000); + }, null, EVT_JOB_STARTED).get(3000); started.add(consumeId);
