(ignite-3) branch main updated: IGNITE-27557 Remove unnecessary pending rows recovery (#7407)

[ibessonov]

This is an automated email from the ASF dual-hosted git repository.

ibessonov pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/main by this push:
     new 3c9a54133ae IGNITE-27557 Remove unnecessary pending rows recovery 
(#7407)
3c9a54133ae is described below

commit 3c9a54133aebaede2dee6e16c02f5bc1eca34f47
Author: Ivan Bessonov <bessonov...@gmail.com>
AuthorDate: Wed Jan 14 13:28:56 2026 +0300

    IGNITE-27557 Remove unnecessary pending rows recovery (#7407)
---
 .../internal/table/distributed/StorageUpdateHandler.java       | 10 +++++++---
 .../apache/ignite/internal/table/distributed/TableManager.java |  8 +++++---
 2 files changed, 12 insertions(+), 6 deletions(-)

diff --git 
a/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/StorageUpdateHandler.java
 
b/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/StorageUpdateHandler.java
index b4d527de580..970bbfa05a4 100644
--- 
a/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/StorageUpdateHandler.java
+++ 
b/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/StorageUpdateHandler.java
@@ -106,10 +106,14 @@ public class StorageUpdateHandler {
     }
 
     /**
-     * Starts the handler doing necessary recovery.
+     * Starts the handler.
+     *
+     * @param onNodeRecovery {@code true} if called on node recovery, {@code 
false} otherwise.
      */
-    public void start() {
-        recoverPendingRows();
+    public void start(boolean onNodeRecovery) {
+        if (onNodeRecovery) {
+            recoverPendingRows();
+        }
     }
 
     private void recoverPendingRows() {
diff --git 
a/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/TableManager.java
 
b/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/TableManager.java
index 6dd39e49f73..39b917c0505 100644
--- 
a/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/TableManager.java
+++ 
b/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/TableManager.java
@@ -893,7 +893,8 @@ public class TableManager implements IgniteTablesInternal, 
IgniteComponent {
                 partitionDataStorage,
                 table,
                 resources.safeTimeTracker(),
-                replicationConfiguration
+                replicationConfiguration,
+                onNodeRecovery
         );
 
         mvGc.addStorage(tablePartitionId, 
partitionUpdateHandlers.gcUpdateHandler);
@@ -1633,7 +1634,8 @@ public class TableManager implements 
IgniteTablesInternal, IgniteComponent {
             PartitionDataStorage partitionDataStorage,
             TableViewInternal table,
             PendingComparableValuesTracker<HybridTimestamp, Void> 
safeTimeTracker,
-            ReplicationConfiguration replicationConfiguration
+            ReplicationConfiguration replicationConfiguration,
+            boolean onNodeRecovery
     ) {
         TableIndexStoragesSupplier indexes = 
table.indexStorageAdapters(partitionId);
 
@@ -1655,7 +1657,7 @@ public class TableManager implements 
IgniteTablesInternal, IgniteComponent {
                 replicationConfiguration,
                 modificationCounter
         );
-        storageUpdateHandler.start();
+        storageUpdateHandler.start(onNodeRecovery);
 
         return new PartitionUpdateHandlers(storageUpdateHandler, 
indexUpdateHandler, gcUpdateHandler);
     }