Repository: incubator-ignite Updated Branches: refs/heads/ignite-929 ef4b77e49 -> 76252dacd
ignite-929 Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/76252dac Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/76252dac Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/76252dac Branch: refs/heads/ignite-929 Commit: 76252dacd9811f2036868d7f3d068c686592331a Parents: ef4b77e Author: avinogradov <avinogra...@gridgain.com> Authored: Thu Jun 11 18:41:43 2015 +0300 Committer: avinogradov <avinogra...@gridgain.com> Committed: Thu Jun 11 18:41:43 2015 +0300 ---------------------------------------------------------------------- .../cache/affinity/IgniteClientNodeAffinityTest.java | 12 ++++++++---- .../DataStreamerMultinodeCreateCacheTest.java | 13 +++++++------ 2 files changed, 15 insertions(+), 10 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/76252dac/modules/core/src/test/java/org/apache/ignite/cache/affinity/IgniteClientNodeAffinityTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/cache/affinity/IgniteClientNodeAffinityTest.java b/modules/core/src/test/java/org/apache/ignite/cache/affinity/IgniteClientNodeAffinityTest.java index 467349f..4244cae 100644 --- a/modules/core/src/test/java/org/apache/ignite/cache/affinity/IgniteClientNodeAffinityTest.java +++ b/modules/core/src/test/java/org/apache/ignite/cache/affinity/IgniteClientNodeAffinityTest.java @@ -127,13 +127,17 @@ public class IgniteClientNodeAffinityTest extends GridCommonAbstractTest { ccfg.setNodeFilter(new TestNodesFilter()); - try (IgniteCache<Integer, Integer> cache = client.createCache(ccfg)) { + IgniteCache<Integer, Integer> cache = client.createCache(ccfg); + checkCache(null, 1); - } - try (IgniteCache<Integer, Integer> cache = client.createCache(ccfg, new NearCacheConfiguration())) { + cache.destroy(); + + cache = client.createCache(ccfg, new NearCacheConfiguration()); + checkCache(null, 1); - } + + cache.destroy(); } /** http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/76252dac/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerMultinodeCreateCacheTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerMultinodeCreateCacheTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerMultinodeCreateCacheTest.java index 12b6458..52f3cb7 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerMultinodeCreateCacheTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerMultinodeCreateCacheTest.java @@ -76,15 +76,16 @@ public class DataStreamerMultinodeCreateCacheTest extends GridCommonAbstractTest while (System.currentTimeMillis() < stopTime) { String cacheName = "cache-" + threadIdx + "-" + (iter % 10); - try (IgniteCache<Integer, String> cache = ignite.getOrCreateCache(cacheName)) { - try (IgniteDataStreamer<Object, Object> stmr = ignite.dataStreamer(cacheName)) { - ((DataStreamerImpl<Object, Object>)stmr).maxRemapCount(0); + IgniteCache<Integer, String> cache = ignite.getOrCreateCache(cacheName); + try (IgniteDataStreamer<Object, Object> stmr = ignite.dataStreamer(cacheName)) { + ((DataStreamerImpl<Object, Object>)stmr).maxRemapCount(0); - for (int i = 0; i < 1000; i++) - stmr.addData(i, i); - } + for (int i = 0; i < 1000; i++) + stmr.addData(i, i); } + cache.destroy(); + iter++; }
