ignite-12163 revert load in oom test
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/f90cae22 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/f90cae22 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/f90cae22 Branch: refs/heads/ignite-5075-pds Commit: f90cae22a8f444d5975b3b2ee1e8181f970e9296 Parents: 294fec4 Author: Dmitriy Govorukhin <[email protected]> Authored: Thu May 18 20:43:34 2017 +0300 Committer: Dmitriy Govorukhin <[email protected]> Committed: Thu May 18 20:43:34 2017 +0300 ---------------------------------------------------------------------- .../database/IgnitePersistentStoreWalTlbSelfTest.java | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/f90cae22/modules/pds/src/test/java/org/apache/ignite/cache/database/IgnitePersistentStoreWalTlbSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/pds/src/test/java/org/apache/ignite/cache/database/IgnitePersistentStoreWalTlbSelfTest.java b/modules/pds/src/test/java/org/apache/ignite/cache/database/IgnitePersistentStoreWalTlbSelfTest.java index e34337b..89bab33 100644 --- a/modules/pds/src/test/java/org/apache/ignite/cache/database/IgnitePersistentStoreWalTlbSelfTest.java +++ b/modules/pds/src/test/java/org/apache/ignite/cache/database/IgnitePersistentStoreWalTlbSelfTest.java @@ -18,7 +18,7 @@ package org.apache.ignite.cache.database; import javax.cache.CacheException; -import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteDataStreamer; import org.apache.ignite.configuration.CacheConfiguration; import org.apache.ignite.configuration.IgniteConfiguration; import org.apache.ignite.configuration.MemoryConfiguration; @@ -118,9 +118,14 @@ public class IgnitePersistentStoreWalTlbSelfTest extends GridCommonAbstractTest boolean locked = true; try { - IgniteCache<Integer, Integer> cache = ig.getOrCreateCache("cache"); + IgniteDataStreamer<Integer, Integer> streamer = ig.dataStreamer(null); - cache.put(1, 1); + for (int i = 0; i < 100_000; i++) { + streamer.addData(i, 1); + + if (i > 0 && i % 10_000 == 0) + info("Done put: " + i); + } } catch (CacheException ignore) { // expected
