Repository: incubator-ignite Updated Branches: refs/heads/ignite-710 46c625d85 -> 994340593
#ignite-710: Fix test DataStreamerMultiThreadedSelfTest. Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/99434059 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/99434059 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/99434059 Branch: refs/heads/ignite-710 Commit: 994340593c720e40fe1e79f812216b818aee63bc Parents: 46c625d Author: ivasilinets <ivasilin...@gridgain.com> Authored: Wed Apr 22 15:08:06 2015 +0300 Committer: ivasilinets <ivasilin...@gridgain.com> Committed: Wed Apr 22 15:08:06 2015 +0300 ---------------------------------------------------------------------- .../datastreamer/DataStreamerMultiThreadedSelfTest.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/99434059/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerMultiThreadedSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerMultiThreadedSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerMultiThreadedSelfTest.java index f1d3a43..231580a 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerMultiThreadedSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerMultiThreadedSelfTest.java @@ -75,12 +75,12 @@ public class DataStreamerMultiThreadedSelfTest extends GridCommonAbstractTest { try (final DataStreamerImpl<Object, Object> dataLdr = (DataStreamerImpl)ignite.dataStreamer(null)) { dataLdr.maxRemapCount(0); - final AtomicInteger id = new AtomicInteger(1); + final AtomicInteger igniteId = new AtomicInteger(1); IgniteInternalFuture<?> fut = GridTestUtils.runMultiThreadedAsync(new Callable<Object>() { @Override public Object call() throws Exception { - for (int i = 1; i < 10; ++i) - startGrid(id.incrementAndGet()); + for (int i = 1; i < 5; ++i) + startGrid(igniteId.incrementAndGet()); return true; } @@ -90,7 +90,6 @@ public class DataStreamerMultiThreadedSelfTest extends GridCommonAbstractTest { while (!fut.isDone()) futs.add(dataLdr.addData(random.nextInt(100000), random.nextInt(100000))); - } for (IgniteFuture f : futs)
