ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject ignite git commit: 1093
Date Sun, 11 Oct 2015 15:07:10 GMT
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 <avinogradov@gridgain.com>
Authored: Sun Oct 11 18:06:57 2015 +0300
Committer: Anton Vinogradov <avinogradov@gridgain.com>
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);
         }
     }
 


Mime
View raw message