ignite-3212 Remove tx from map if 'onStarted' failed.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/a70ff4c4 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/a70ff4c4 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/a70ff4c4 Branch: refs/heads/ignite-1232 Commit: a70ff4c40d9f149510b148467b1dd6ce3ad5db0d Parents: 5e91594 Author: sboikov <[email protected]> Authored: Thu Jun 23 12:13:05 2016 +0300 Committer: sboikov <[email protected]> Committed: Thu Jun 23 12:13:05 2016 +0300 ---------------------------------------------------------------------- .../internal/processors/cache/transactions/IgniteTxManager.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/a70ff4c4/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java index e8d20b6..63c9919 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java @@ -568,6 +568,10 @@ public class IgniteTxManager extends GridCacheSharedManagerAdapter { ", tx=" + tx + ']'; if (isCompleted(tx)) { + ConcurrentMap<GridCacheVersion, IgniteInternalTx> txIdMap = transactionMap(tx); + + txIdMap.remove(tx.xidVersion(), tx); + if (log.isDebugEnabled()) log.debug("Attempt to start a completed transaction (will ignore): " + tx);
