IGNITE-889 - Fixed test.
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/93ba805a Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/93ba805a Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/93ba805a Branch: refs/heads/ignite-889 Commit: 93ba805a236a4ec60aeb0abcfa7a1aff5d7ee759 Parents: 72b6ce2 Author: Alexey Goncharuk <agoncha...@gridgain.com> Authored: Thu May 14 12:54:28 2015 -0700 Committer: Alexey Goncharuk <agoncha...@gridgain.com> Committed: Thu May 14 12:54:28 2015 -0700 ---------------------------------------------------------------------- .../cache/integration/IgniteCacheTxStoreSessionTest.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/93ba805a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/integration/IgniteCacheTxStoreSessionTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/integration/IgniteCacheTxStoreSessionTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/integration/IgniteCacheTxStoreSessionTest.java index 269b9ae..554cbf8 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/integration/IgniteCacheTxStoreSessionTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/integration/IgniteCacheTxStoreSessionTest.java @@ -66,6 +66,9 @@ public class IgniteCacheTxStoreSessionTest extends IgniteCacheStoreSessionAbstra testTxPutRemove(null, null); + // Need to clear cache before next test to trigger store load on get. + jcache(0).withSkipStore().removeAll(); + for (TransactionConcurrency concurrency : F.asList(PESSIMISTIC)) { for (TransactionIsolation isolation : F.asList(REPEATABLE_READ)) { testTxPut(jcache(0), concurrency, isolation); @@ -136,6 +139,8 @@ public class IgniteCacheTxStoreSessionTest extends IgniteCacheStoreSessionAbstra try (Transaction tx = startTx(concurrency, isolation)) { log.info("Do tx get."); + expData.add(new ExpectedData(false, "load", new HashMap<>(), cache.getName())); + cache.get(key1); log.info("Do tx put.");
