This is an automated email from the ASF dual-hosted git repository. av pushed a commit to branch ignite-20177 in repository https://gitbox.apache.org/repos/asf/ignite.git
commit 305f3a853d0ffa0d3692e0ec146c3c45d6456719 Author: Anton Vinogradov <a...@apache.org> AuthorDate: Tue Aug 8 16:06:17 2023 +0300 WIP --- .../cache/distributed/near/GridNearTxFinishFuture.java | 12 +++++------- 1 file changed, 5 insertions(+), 7 deletions(-) diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java index 40df946166d..e30e9d571a6 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxFinishFuture.java @@ -475,13 +475,13 @@ public final class GridNearTxFinishFuture<K, V> extends GridCacheCompoundIdentit if (mapping != null) { assert !hasFutures() || isDone() : futures(); - finish(1, mapping, commit, !clearThreadMap); + finish(1, mapping, commit); } } else { assert !hasFutures() || isDone() : futures(); - finish(mappings.mappings(), commit, !clearThreadMap); + finish(mappings.mappings(), commit); } } @@ -740,23 +740,21 @@ public final class GridNearTxFinishFuture<K, V> extends GridCacheCompoundIdentit /** * @param mappings Mappings. * @param commit Commit flag. - * @param useCompletedVer {@code True} if need to add completed version on finish. */ - private void finish(Iterable<GridDistributedTxMapping> mappings, boolean commit, boolean useCompletedVer) { + private void finish(Iterable<GridDistributedTxMapping> mappings, boolean commit) { int miniId = 0; // Create mini futures. for (GridDistributedTxMapping m : mappings) - finish(++miniId, m, commit, useCompletedVer); + finish(++miniId, m, commit); } /** * @param miniId Mini future ID. * @param m Mapping. * @param commit Commit flag. - * @param useCompletedVer {@code True} if need to add completed version on finish. */ - private void finish(int miniId, GridDistributedTxMapping m, boolean commit, boolean useCompletedVer) { + private void finish(int miniId, GridDistributedTxMapping m, boolean commit) { ClusterNode n = m.primary(); assert !m.empty() || m.queryUpdate() : m + " " + tx.state();