Repository: ignite Updated Branches: refs/heads/ignite-3478 761e43d30 -> fb3ee2478
ignite-3478 Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/fb3ee247 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/fb3ee247 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/fb3ee247 Branch: refs/heads/ignite-3478 Commit: fb3ee2478eccad3a9ab12c42ef99d0364af5194f Parents: 761e43d Author: sboikov <[email protected]> Authored: Fri Sep 29 14:51:28 2017 +0300 Committer: sboikov <[email protected]> Committed: Fri Sep 29 14:51:28 2017 +0300 ---------------------------------------------------------------------- .../cache/mvcc/CacheMvccTransactionsTest.java | 18 +++++++++++++++--- 1 file changed, 15 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/fb3ee247/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/mvcc/CacheMvccTransactionsTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/mvcc/CacheMvccTransactionsTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/mvcc/CacheMvccTransactionsTest.java index 1b70747..2d6afb4 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/mvcc/CacheMvccTransactionsTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/mvcc/CacheMvccTransactionsTest.java @@ -1828,10 +1828,20 @@ public class CacheMvccTransactionsTest extends GridCommonAbstractTest { for (Integer key : keys) vals.put(key, i); - try (Transaction tx = getNode.transactions().txStart(PESSIMISTIC, REPEATABLE_READ)) { - cache.putAll(vals); + while (true) { + try (Transaction tx = getNode.transactions().txStart(PESSIMISTIC, REPEATABLE_READ)) { + cache.putAll(vals); - tx.commit(); + tx.commit(); + + break; + } + catch (Exception e) { + if (!X.hasCause(e, ClusterTopologyException.class)) + fail("Unexpected error: " + e); + else + info("Tx error, need retry: " + e); + } } } @@ -2224,6 +2234,8 @@ public class CacheMvccTransactionsTest extends GridCommonAbstractTest { stopGrid(0); + awaitPartitionMapExchange(); + checkCoordinatorsConsistency(5); }
