(ignite-3) branch main updated: IGNITE-27595 Reduce the amount of pending rows logs (#7426)

[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 9f05f624157 IGNITE-27595 Reduce the amount of pending rows logs (#7426)
9f05f624157 is described below

commit 9f05f624157483a9740ce7c7710b0ac5bf9d3dc7
Author: Ivan Bessonov <bessonov...@gmail.com>
AuthorDate: Fri Jan 16 17:53:37 2026 +0300

    IGNITE-27595 Reduce the amount of pending rows logs (#7426)
---
 .../table/distributed/StorageUpdateHandler.java        | 18 +++++++++---------
 1 file changed, 9 insertions(+), 9 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 970bbfa05a4..09c77fabbb4 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
@@ -117,8 +117,6 @@ public class StorageUpdateHandler {
     }
 
     private void recoverPendingRows() {
-        LOG.info("Recovering pending rows [tableId={}, partitionIndex={}]", 
storage.tableId(), storage.partitionId());
-
         long startNanos = System.nanoTime();
 
         int count = 0;
@@ -138,13 +136,15 @@ public class StorageUpdateHandler {
             }
         }
 
-        LOG.info(
-                "Recovered pending rows [tableId={}, partitionIndex={}, 
count={}, duration={}ms]",
-                storage.tableId(),
-                storage.partitionId(),
-                count,
-                NANOSECONDS.toMillis(System.nanoTime() - startNanos)
-        );
+        if (count != 0 && LOG.isInfoEnabled()) {
+            LOG.info(
+                    "Recovered pending rows [tableId={}, partitionId={}, 
count={}, duration={}ms]",
+                    storage.tableId(),
+                    storage.partitionId(),
+                    count,
+                    NANOSECONDS.toMillis(System.nanoTime() - startNanos)
+            );
+        }
     }
 
     /**