Repository: ignite Updated Branches: refs/heads/ignite-1093-2 568b41cfc -> f6d35e4dd
1093 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/f6d35e4d Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/f6d35e4d Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/f6d35e4d Branch: refs/heads/ignite-1093-2 Commit: f6d35e4ddd5bfeebafc2bef57d38ef74dcee58d0 Parents: 568b41c Author: Anton Vinogradov <[email protected]> Authored: Sun Oct 11 18:06:57 2015 +0300 Committer: Anton Vinogradov <[email protected]> Committed: Sun Oct 11 18:06:57 2015 +0300 ---------------------------------------------------------------------- .../GridCacheRebalancingSyncSelfTest.java | 17 +++++------------ 1 file changed, 5 insertions(+), 12 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/f6d35e4d/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/rebalancing/GridCacheRebalancingSyncSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/rebalancing/GridCacheRebalancingSyncSelfTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/rebalancing/GridCacheRebalancingSyncSelfTest.java index 2003ec2..0b2c143 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/rebalancing/GridCacheRebalancingSyncSelfTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/rebalancing/GridCacheRebalancingSyncSelfTest.java @@ -21,7 +21,6 @@ import java.util.HashMap; import java.util.Map; import org.apache.ignite.Ignite; import org.apache.ignite.IgniteCheckedException; -import org.apache.ignite.IgniteDataStreamer; import org.apache.ignite.cache.CacheMode; import org.apache.ignite.cache.CacheRebalanceMode; import org.apache.ignite.configuration.CacheConfiguration; @@ -97,7 +96,7 @@ public class GridCacheRebalancingSyncSelfTest extends GridCommonAbstractTest { cachePCfg2.setRebalanceMode(CacheRebalanceMode.SYNC); cachePCfg2.setBackups(1); cachePCfg2.setRebalanceOrder(2); - //cachePCfg2.setRebalanceDelay(5000);//Known issue, deadlock in case of low priority rebalancing delay. + //cachePCfg2.setRebalanceDelay(5000);//Known issue, deadlock in case of low priority rebalancing delay. CacheConfiguration<Integer, Integer> cacheRCfg = new CacheConfiguration<>(); @@ -133,17 +132,11 @@ public class GridCacheRebalancingSyncSelfTest extends GridCommonAbstractTest { * @param ignite Ignite. */ protected void generateData(Ignite ignite, String name, int from, int iter) { - try (IgniteDataStreamer<Integer, Integer> stmr = ignite.dataStreamer(name)) { - stmr.allowOverwrite(true); - - for (int i = from; i < from + TEST_SIZE; i++) { - if (i % (TEST_SIZE / 10) == 0) - log.info("Prepared " + i * 100 / (TEST_SIZE) + "% entries (" + TEST_SIZE + ")."); - - stmr.addData(i, i + name.hashCode() + iter); - } + for (int i = from; i < from + TEST_SIZE; i++) { + if (i % (TEST_SIZE / 10) == 0) + log.info("Prepared " + i * 100 / (TEST_SIZE) + "% entries (" + TEST_SIZE + ")."); - stmr.flush(); + ignite.cache(name).put(i, i + name.hashCode() + iter); } }
