From 4fbe4d413ac2bb40189ed4a4f0d6a32fe070a2c0 Mon Sep 17 00:00:00 2001
From: Vladimir Steshin <vladsz83@gmail.com>
Date: Mon, 18 Mar 2024 15:43:31 +0300
Subject: [PATCH] IGNITE-21636 MVCC code cleanup and abbreviation fixes
 (#11259)

---
 .../org/apache/ignite/dump/DumpConsumer.java  |  3 +-
 .../ignite/dump/DumpReaderConfiguration.java  | 10 +++---
 .../pagemem/wal/record/UnwrapDataEntry.java   |  5 +--
 .../cache/ValidationOnNodeJoinUtils.java      |  2 +-
 .../cache/persistence/snapshot/dump/Dump.java | 28 ++++++++--------
 .../cache/persistence/tree/io/PageIO.java     | 14 +++-----
 .../snapshot/dump/AbstractCacheDumpTest.java  | 32 +++++++++----------
 .../junits/common/GridCommonAbstractTest.java |  6 ++--
 .../IgniteLoggingSelfTestSuite.java           |  1 -
 .../query/h2/GridCacheTwoStepQuery.java       |  6 ----
 .../processors/query/h2/QueryParser.java      |  7 +---
 .../query/h2/QueryParserResultDml.java        |  6 ----
 .../query/h2/sql/GridSqlQuerySplitter.java    |  1 -
 13 files changed, 49 insertions(+), 72 deletions(-)

diff --git a/modules/core/src/main/java/org/apache/ignite/dump/DumpConsumer.java b/modules/core/src/main/java/org/apache/ignite/dump/DumpConsumer.java
index aec3a02c99789..d06ab32d36a91 100644
--- a/modules/core/src/main/java/org/apache/ignite/dump/DumpConsumer.java
+++ b/modules/core/src/main/java/org/apache/ignite/dump/DumpConsumer.java
@@ -21,11 +21,10 @@
 import org.apache.ignite.binary.BinaryType;
 import org.apache.ignite.cdc.TypeMapping;
 import org.apache.ignite.internal.processors.cache.StoredCacheData;
-import org.apache.ignite.internal.processors.cache.persistence.snapshot.dump.Dump;
 import org.apache.ignite.lang.IgniteExperimental;
 
 /**
- * Consumer of {@link Dump}.
+ * Consumer of a cache dump.
  * This consumer will receive all {@link DumpEntry} stored in cache dump during {@code IgniteDumpReader} application invocation.
  * The lifecycle of the consumer is the following:
  * <ul>
diff --git a/modules/core/src/main/java/org/apache/ignite/dump/DumpReaderConfiguration.java b/modules/core/src/main/java/org/apache/ignite/dump/DumpReaderConfiguration.java
index 619c532b1ffbd..aeb62fba05b6b 100644
--- a/modules/core/src/main/java/org/apache/ignite/dump/DumpReaderConfiguration.java
+++ b/modules/core/src/main/java/org/apache/ignite/dump/DumpReaderConfiguration.java
@@ -57,7 +57,7 @@ public class DumpReaderConfiguration {
     private final boolean keepBinary;
 
     /** Cache group names. */
-    private String[] cacheGroupNames;
+    private final String[] cacheGrpNames;
 
     /** Skip copies. */
     private final boolean skipCopies;
@@ -80,7 +80,7 @@ public DumpReaderConfiguration(File dir, DumpConsumer cnsmr) {
      * @param timeout Timeout of dump reader invocation.
      * @param failFast Stop processing partitions if consumer fail to process one.
      * @param keepBinary If {@code true} then don't deserialize {@link KeyCacheObject} and {@link CacheObject}.
-     * @param cacheGroupNames Cache group names.
+     * @param cacheGrpNames Cache group names.
      * @param skipCopies Skip copies.
      * @param encSpi Encryption SPI.
      */
@@ -91,7 +91,7 @@ public DumpReaderConfiguration(
         Duration timeout,
         boolean failFast,
         boolean keepBinary,
-        String[] cacheGroupNames,
+        String[] cacheGrpNames,
         boolean skipCopies,
         EncryptionSpi encSpi
     ) {
@@ -101,7 +101,7 @@ public DumpReaderConfiguration(
         this.timeout = timeout;
         this.failFast = failFast;
         this.keepBinary = keepBinary;
-        this.cacheGroupNames = cacheGroupNames;
+        this.cacheGrpNames = cacheGrpNames;
         this.skipCopies = skipCopies;
         this.encSpi = encSpi;
     }
@@ -138,7 +138,7 @@ public boolean keepBinary() {
 
     /** @return Cache group names. */
     public String[] cacheGroupNames() {
-        return cacheGroupNames;
+        return cacheGrpNames;
     }
 
     /** @return Skip copies. */
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/UnwrapDataEntry.java b/modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/UnwrapDataEntry.java
index f69f579084f69..cba9f37928628 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/UnwrapDataEntry.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/pagemem/wal/record/UnwrapDataEntry.java
@@ -33,8 +33,8 @@ public class UnwrapDataEntry extends DataEntry implements UnwrappedDataEntry {
     /** Cache object value context. Context is used for unwrapping objects. */
     private final CacheObjectValueContext cacheObjValCtx;
 
-    /** Keep binary. This flag disables converting of non primitive types (BinaryObjects). */
-    private boolean keepBinary;
+    /** Keep binary. This flag disables converting of non-primitive types (BinaryObjects). */
+    private final boolean keepBinary;
 
     /**
      * @param cacheId Cache ID.
@@ -103,6 +103,7 @@ public static Object unwrapKey(KeyCacheObject key, boolean keepBinary, CacheObje
         if (unwrapped instanceof BinaryObject) {
             if (keepBinary)
                 return unwrapped;
+
             unwrapped = ((BinaryObject)unwrapped).deserialize();
         }
 
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/ValidationOnNodeJoinUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/ValidationOnNodeJoinUtils.java
index c596ca5608cf9..b17248166fa84 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/ValidationOnNodeJoinUtils.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/ValidationOnNodeJoinUtils.java
@@ -629,7 +629,7 @@ private static void checkMemoryConfiguration(ClusterNode rmt, GridKernalContext
     ) {
         if (!node.isClient()) {
             for (DynamicCacheDescriptor desc : map.values()) {
-                CacheConfiguration cfg = desc.cacheConfiguration();
+                CacheConfiguration<?, ?> cfg = desc.cacheConfiguration();
 
                 if (cfg.getAffinity() instanceof RendezvousAffinityFunction) {
                     RendezvousAffinityFunction aff = (RendezvousAffinityFunction)cfg.getAffinity();
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/dump/Dump.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/dump/Dump.java
index 7c149118a4292..f0e64a88e2a44 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/dump/Dump.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/dump/Dump.java
@@ -78,7 +78,7 @@
 import static org.apache.ignite.internal.processors.cache.persistence.wal.reader.StandaloneGridKernalContext.startAllComponents;
 
 /**
- * This class provides ability to work with saved cache dump.
+ * This class provides the ability to work with saved cache dump.
  */
 public class Dump implements AutoCloseable {
     /** Snapshot meta. */
@@ -200,7 +200,7 @@ public List<String> nodesDirectories() {
 
     /** @return List of snapshot metadata saved in {@link #dumpDir}. */
     public List<SnapshotMetadata> metadata() throws IOException, IgniteCheckedException {
-        return metadata;
+        return Collections.unmodifiableList(metadata);
     }
 
     /** @return List of snapshot metadata saved in {@link #dumpDir}. */
@@ -228,13 +228,13 @@ private static List<SnapshotMetadata> metadata(File dumpDir, @Nullable String co
 
     /**
      * @param node Node directory name.
-     * @param group Group id.
+     * @param grp Group id.
      * @return List of cache configs saved in dump for group.
      */
-    public List<StoredCacheData> configs(String node, int group) {
+    public List<StoredCacheData> configs(String node, int grp) {
         JdkMarshaller marsh = MarshallerUtils.jdkMarshaller(cctx.igniteInstanceName());
 
-        return Arrays.stream(FilePageStoreManager.cacheDataFiles(dumpGroupDirectory(node, group))).map(f -> {
+        return Arrays.stream(FilePageStoreManager.cacheDataFiles(dumpGroupDirectory(node, grp))).map(f -> {
             try {
                 return readCacheData(f, marsh, cctx.config());
             }
@@ -246,13 +246,13 @@ public List<StoredCacheData> configs(String node, int group) {
 
     /**
      * @param node Node directory name.
-     * @param group Group id.
+     * @param grp Group id.
      * @return Dump iterator.
      */
-    public List<Integer> partitions(String node, int group) {
+    public List<Integer> partitions(String node, int grp) {
         String suffix = comprParts ? DUMP_FILE_EXT + ZIP_SUFFIX : DUMP_FILE_EXT;
 
-        File[] parts = dumpGroupDirectory(node, group)
+        File[] parts = dumpGroupDirectory(node, grp)
             .listFiles(f -> f.getName().startsWith(PART_FILE_PREFIX) && f.getName().endsWith(suffix));
 
         if (parts == null)
@@ -265,10 +265,10 @@ public List<Integer> partitions(String node, int group) {
 
     /**
      * @param node Node directory name.
-     * @param group Group id.
+     * @param grp Group id.
      * @return Dump iterator.
      */
-    public DumpedPartitionIterator iterator(String node, int group, int part) {
+    public DumpedPartitionIterator iterator(String node, int grp, int part) {
         FileIOFactory ioFactory = comprParts
             ? (file, modes) -> new ReadOnlyUnzipFileIO(file)
             : (file, modes) -> new ReadOnlyBufferedFileIO(file);
@@ -276,7 +276,7 @@ public DumpedPartitionIterator iterator(String node, int group, int part) {
         FileIO dumpFile;
 
         try {
-            dumpFile = ioFactory.create(new File(dumpGroupDirectory(node, group), dumpPartFileName(part, comprParts)));
+            dumpFile = ioFactory.create(new File(dumpGroupDirectory(node, grp), dumpPartFileName(part, comprParts)));
         }
         catch (IOException e) {
             throw new RuntimeException(e);
@@ -333,7 +333,7 @@ private void advance() {
                     return;
 
                 try {
-                    next = serializer.read(dumpFile, group, part);
+                    next = serializer.read(dumpFile, grp, part);
                 }
                 catch (IOException | IgniteCheckedException e) {
                     throw new IgniteException(e);
@@ -362,7 +362,7 @@ public File dumpDirectory() {
     }
 
     /** */
-    private File dumpGroupDirectory(String node, int groupId) {
+    private File dumpGroupDirectory(String node, int grpId) {
         File nodeDir = Paths.get(dumpDir.getAbsolutePath(), DFLT_STORE_DIR, node).toFile();
 
         assert nodeDir.exists() && nodeDir.isDirectory();
@@ -377,7 +377,7 @@ private File dumpGroupDirectory(String node, int groupId) {
                 ? f.getName().replaceFirst(CACHE_DIR_PREFIX, "")
                 : f.getName().replaceFirst(CACHE_GRP_DIR_PREFIX, "");
 
-            return groupId == CU.cacheId(grpName);
+            return grpId == CU.cacheId(grpName);
         });
 
         if (grpDirs.length != 1)
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/tree/io/PageIO.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/tree/io/PageIO.java
index 074783e332e5d..cb54be0a7ae1d 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/tree/io/PageIO.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/tree/io/PageIO.java
@@ -111,10 +111,10 @@ public abstract class PageIO {
     public static final short MAX_PAYLOAD_SIZE = 2048;
 
     /** */
-    private static List<IOVersions<? extends BPlusInnerIO<?>>> h2ExtraInnerIOs = new ArrayList<>(MAX_PAYLOAD_SIZE);
+    private static final List<IOVersions<? extends BPlusInnerIO<?>>> h2ExtraInnerIOs = new ArrayList<>(MAX_PAYLOAD_SIZE);
 
     /** */
-    private static List<IOVersions<? extends BPlusLeafIO<?>>> h2ExtraLeafIOs = new ArrayList<>(MAX_PAYLOAD_SIZE);
+    private static final List<IOVersions<? extends BPlusLeafIO<?>>> h2ExtraLeafIOs = new ArrayList<>(MAX_PAYLOAD_SIZE);
 
     /** */
     private static List<IOVersions<? extends BPlusInnerIO<?>>> h2ExtraMvccInnerIOs = new ArrayList<>(MAX_PAYLOAD_SIZE);
@@ -632,12 +632,8 @@ public static boolean isIndexPage(int pageType) {
         )
             return true;
 
-        if ((T_H2_EX_REF_INNER_START <= pageType && pageType <= T_H2_EX_REF_INNER_END) ||
-            (T_H2_EX_REF_MVCC_INNER_START <= pageType && pageType <= T_H2_EX_REF_MVCC_INNER_END)
-        )
-            return true;
-
-        return false;
+        return (T_H2_EX_REF_INNER_START <= pageType && pageType <= T_H2_EX_REF_INNER_END) ||
+            (T_H2_EX_REF_MVCC_INNER_START <= pageType && pageType <= T_H2_EX_REF_MVCC_INNER_END);
     }
 
     /** {@inheritDoc} */
@@ -841,7 +837,7 @@ public static <Q extends BPlusIO<?>> Q getBPlusIO(int type, int ver) throws Igni
      * @return Index page type.
      */
     public static IndexPageType deriveIndexPageType(long pageAddr) {
-        int pageIoType = PageIO.getType(pageAddr);
+        int pageIoType = getType(pageAddr);
         switch (pageIoType) {
             case T_DATA_REF_INNER:
             case T_DATA_REF_MVCC_INNER:
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/dump/AbstractCacheDumpTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/dump/AbstractCacheDumpTest.java
index bdcfab73f25fd..678b2d9ab938f 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/dump/AbstractCacheDumpTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/dump/AbstractCacheDumpTest.java
@@ -313,11 +313,11 @@ void checkDump(IgniteEx ign, String name, boolean expectedComprParts) throws Exc
     void checkDump(
         IgniteEx ign,
         String name,
-        String[] cacheGroupNames,
+        String[] cacheGrpNames,
         Set<String> expectedFoundCaches,
         int expectedDfltDumpSz,
         int expectedGrpDumpSz,
-        int expectedCount,
+        int expectedCnt,
         boolean skipCopies,
         boolean expectedComprParts
     ) throws Exception {
@@ -417,7 +417,7 @@ else if (!cacheName.equals(DEFAULT_CACHE_NAME))
                 assertEquals(expectedDfltDumpSz, dfltDumpSz);
                 assertEquals(expectedGrpDumpSz, grpDumpSz);
 
-                IntStream.range(0, expectedCount).forEach(key -> assertTrue(keys.contains(key)));
+                IntStream.range(0, expectedCnt).forEach(key -> assertTrue(keys.contains(key)));
             }
         };
 
@@ -428,7 +428,7 @@ else if (!cacheName.equals(DEFAULT_CACHE_NAME))
                 DFLT_THREAD_CNT, DFLT_TIMEOUT,
                 true,
                 false,
-                cacheGroupNames,
+                cacheGrpNames,
                 skipCopies,
                 null
             ),
@@ -556,14 +556,14 @@ public static String invokeCheckCommand(IgniteEx ign, String name, String snpPat
     }
 
     /** */
-    void createDump(IgniteEx ign, String name, @Nullable Collection<String> cacheGroupNames) {
-        createDump(ign, name, cacheGroupNames, false);
+    void createDump(IgniteEx ign, String name, @Nullable Collection<String> cacheGrpNames) {
+        createDump(ign, name, cacheGrpNames, false);
     }
 
     /** */
-    void createDump(IgniteEx ign, String name, @Nullable Collection<String> cacheGroupNames, boolean comprParts) {
+    void createDump(IgniteEx ign, String name, @Nullable Collection<String> cacheGrpNames, boolean comprParts) {
         ign.context().cache().context().snapshotMgr()
-            .createSnapshot(name, null, cacheGroupNames, false, onlyPrimary, true, comprParts, encrypted).get();
+            .createSnapshot(name, null, cacheGrpNames, false, onlyPrimary, true, comprParts, encrypted).get();
     }
 
     /** */
@@ -588,7 +588,7 @@ public abstract static class TestDumpConsumer implements DumpConsumer {
         private boolean typesCb;
 
         /** */
-        private boolean mappingcCb;
+        private boolean mappingCb;
 
         /** */
         private boolean cacheCfgCb;
@@ -596,7 +596,7 @@ public abstract static class TestDumpConsumer implements DumpConsumer {
         /** {@inheritDoc} */
         @Override public void start() {
             assertFalse(started);
-            assertFalse(mappingcCb);
+            assertFalse(mappingCb);
             assertFalse(typesCb);
             assertFalse(cacheCfgCb);
             assertFalse(stopped);
@@ -607,18 +607,18 @@ public abstract static class TestDumpConsumer implements DumpConsumer {
         /** {@inheritDoc} */
         @Override public void onMappings(Iterator<TypeMapping> mappings) {
             assertTrue(started);
-            assertFalse(mappingcCb);
+            assertFalse(mappingCb);
             assertFalse(typesCb);
             assertFalse(cacheCfgCb);
             assertFalse(stopped);
 
-            mappingcCb = true;
+            mappingCb = true;
         }
 
         /** {@inheritDoc} */
         @Override public void onTypes(Iterator<BinaryType> types) {
             assertTrue(started);
-            assertTrue(mappingcCb);
+            assertTrue(mappingCb);
             assertFalse(typesCb);
             assertFalse(cacheCfgCb);
             assertFalse(stopped);
@@ -629,7 +629,7 @@ public abstract static class TestDumpConsumer implements DumpConsumer {
         /** {@inheritDoc} */
         @Override public void onCacheConfigs(Iterator<StoredCacheData> caches) {
             assertTrue(started);
-            assertTrue(mappingcCb);
+            assertTrue(mappingCb);
             assertTrue(typesCb);
             assertFalse(cacheCfgCb);
             assertFalse(stopped);
@@ -641,7 +641,7 @@ public abstract static class TestDumpConsumer implements DumpConsumer {
         @Override public void stop() {
             assertTrue(started);
             assertTrue(typesCb);
-            assertTrue(mappingcCb);
+            assertTrue(mappingCb);
             assertTrue(cacheCfgCb);
             assertFalse(stopped);
 
@@ -652,7 +652,7 @@ public abstract static class TestDumpConsumer implements DumpConsumer {
         public void check() {
             assertTrue(started);
             assertTrue(typesCb);
-            assertTrue(mappingcCb);
+            assertTrue(mappingCb);
             assertTrue(cacheCfgCb);
             assertTrue(stopped);
         }
diff --git a/modules/core/src/test/java/org/apache/ignite/testframework/junits/common/GridCommonAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/testframework/junits/common/GridCommonAbstractTest.java
index 49a8783f8d65f..1e9b9f8b8c3a4 100755
--- a/modules/core/src/test/java/org/apache/ignite/testframework/junits/common/GridCommonAbstractTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/testframework/junits/common/GridCommonAbstractTest.java
@@ -2554,7 +2554,7 @@ protected Set<String> getNotRegisteredMbeans(Ignite ignite, String... namesToChe
      * @return {@code Set} of metrics methods that have forbidden return types.
      * @throws Exception If failed to obtain metrics.
      */
-    protected Set<String> getInvalidMbeansMethods(Ignite ignite) throws Exception {
+    protected Set<String> getInvalidMbeansMethods(Ignite ignite) {
         Set<String> sysMetricsPackages = new HashSet<>();
         sysMetricsPackages.add("sun.management");
         sysMetricsPackages.add("javax.management");
@@ -2571,7 +2571,7 @@ protected Set<String> getInvalidMbeansMethods(Ignite ignite) throws Exception {
             if (sysMetricsPackages.stream().anyMatch(clsName::startsWith))
                 continue;
 
-            Class c;
+            Class<?> c;
 
             try {
                 c = Class.forName(clsName);
@@ -2582,7 +2582,7 @@ protected Set<String> getInvalidMbeansMethods(Ignite ignite) throws Exception {
                 continue;
             }
 
-            for (Class interf : c.getInterfaces()) {
+            for (Class<?> interf : c.getInterfaces()) {
                 for (Method m : interf.getMethods()) {
                     if (!m.isAnnotationPresent(MXBeanDescription.class))
                         continue;
diff --git a/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteLoggingSelfTestSuite.java b/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteLoggingSelfTestSuite.java
index 93604f289e843..a64b234b1c435 100644
--- a/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteLoggingSelfTestSuite.java
+++ b/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteLoggingSelfTestSuite.java
@@ -34,5 +34,4 @@ public class IgniteLoggingSelfTestSuite {
     public static void setUpClass() {
         JUnitTeamcityReporter.suite = IgniteLoggingSelfTestSuite.class.getName();
     }
-
 }
diff --git a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/GridCacheTwoStepQuery.java b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/GridCacheTwoStepQuery.java
index aad80a1b66d64..c8c8de4166d5f 100644
--- a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/GridCacheTwoStepQuery.java
+++ b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/GridCacheTwoStepQuery.java
@@ -64,9 +64,6 @@ public class GridCacheTwoStepQuery {
     /** */
     private final PartitionResult derivedPartitions;
 
-    /** */
-    private final boolean mvccEnabled;
-
     /** Number of positional arguments in the sql. */
     private final int paramsCnt;
 
@@ -85,7 +82,6 @@ public class GridCacheTwoStepQuery {
      * @param replicatedOnly Replicated only flag.
      * @param derivedPartitions Derived partitions.
      * @param cacheIds Cache ids.
-     * @param mvccEnabled Mvcc flag.
      * @param locSplit Local split flag.
      * @param treatReplicatedAsPartitioned Treat replicated as partitioned flag.
      */
@@ -101,7 +97,6 @@ public GridCacheTwoStepQuery(
         boolean replicatedOnly,
         PartitionResult derivedPartitions,
         List<Integer> cacheIds,
-        boolean mvccEnabled,
         boolean locSplit,
         boolean treatReplicatedAsPartitioned
     ) {
@@ -116,7 +111,6 @@ public GridCacheTwoStepQuery(
         this.distributedJoins = distributedJoins;
         this.derivedPartitions = derivedPartitions;
         this.cacheIds = cacheIds;
-        this.mvccEnabled = mvccEnabled;
         this.locSplit = locSplit;
         this.mapQrys = mapQrys;
         this.replicatedOnly = replicatedOnly;
diff --git a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/QueryParser.java b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/QueryParser.java
index e99dea7229822..ec27eee5da319 100644
--- a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/QueryParser.java
+++ b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/QueryParser.java
@@ -667,12 +667,7 @@ private QueryParserResultDml prepareDmlStatement(QueryDescriptor planKey, Prepar
                 throw new IgniteSQLException("Failed to prepare update plan.", e);
         }
 
-        return new QueryParserResultDml(
-            stmt,
-            false,
-            streamTbl,
-            plan
-        );
+        return new QueryParserResultDml(stmt, streamTbl, plan);
     }
 
     /**
diff --git a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/QueryParserResultDml.java b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/QueryParserResultDml.java
index 9d5626db29632..8db448128eb27 100644
--- a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/QueryParserResultDml.java
+++ b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/QueryParserResultDml.java
@@ -29,9 +29,6 @@ public class QueryParserResultDml {
     /** Command. */
     private final GridSqlStatement stmt;
 
-    /** MVCC enabled flag. */
-    private final boolean mvccEnabled;
-
     /** Streamer table. */
     private final GridH2Table streamTbl;
 
@@ -42,18 +39,15 @@ public class QueryParserResultDml {
      * Constructor.
      *
      * @param stmt Command.
-     * @param mvccEnabled Whether MVCC is enabled.
      * @param streamTbl Streamer table.
      * @param plan Update plan.
      */
     public QueryParserResultDml(
         GridSqlStatement stmt,
-        boolean mvccEnabled,
         @Nullable GridH2Table streamTbl,
         UpdatePlan plan
     ) {
         this.stmt = stmt;
-        this.mvccEnabled = mvccEnabled;
         this.streamTbl = streamTbl;
         this.plan = plan;
     }
diff --git a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/sql/GridSqlQuerySplitter.java b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/sql/GridSqlQuerySplitter.java
index bfa265d447487..40c487d826669 100644
--- a/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/sql/GridSqlQuerySplitter.java
+++ b/modules/indexing/src/main/java/org/apache/ignite/internal/processors/query/h2/sql/GridSqlQuerySplitter.java
@@ -336,7 +336,6 @@ private static GridCacheTwoStepQuery split0(
             replicatedOnly,
             splitter.extractor.mergeMapQueries(splitter.mapSqlQrys),
             cacheIds,
-            false,
             locSplit,
             treatReplicatedAsPartitioned
         );