(ignite-3) branch main updated: IGNITE-28505 Prevent log flooding caused by TX operations when a node… (#7968)

[sk0x50]

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

sk0x50 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 b90e6b4f600 IGNITE-28505 Prevent log flooding caused by TX operations 
when a node… (#7968)
b90e6b4f600 is described below

commit b90e6b4f6003ad132a9ca25a53947516352c6b2a
Author: Egor <egor.kuts2...@yandex.ru>
AuthorDate: Thu Apr 16 16:12:30 2026 +0700

    IGNITE-28505 Prevent log flooding caused by TX operations when a node… 
(#7968)
    
    Co-authored-by: Egor Kuts <i...@ekuts.ru>
---
 .../handlers/TxCleanupRecoveryRequestHandler.java        | 16 +++++++++-------
 1 file changed, 9 insertions(+), 7 deletions(-)

diff --git 
a/modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/handlers/TxCleanupRecoveryRequestHandler.java
 
b/modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/handlers/TxCleanupRecoveryRequestHandler.java
index 9fd5ddeedbd..43514cb76f3 100644
--- 
a/modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/handlers/TxCleanupRecoveryRequestHandler.java
+++ 
b/modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/handlers/TxCleanupRecoveryRequestHandler.java
@@ -31,8 +31,10 @@ import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.CopyOnWriteArrayList;
 import org.apache.ignite.internal.failure.FailureContext;
 import org.apache.ignite.internal.failure.FailureProcessor;
+import org.apache.ignite.internal.lang.ComponentStoppingException;
 import org.apache.ignite.internal.lang.IgniteBiTuple;
 import org.apache.ignite.internal.lang.IgniteInternalException;
+import org.apache.ignite.internal.lang.NodeStoppingException;
 import org.apache.ignite.internal.logger.IgniteLogger;
 import org.apache.ignite.internal.logger.IgniteThrottledLogger;
 import org.apache.ignite.internal.logger.Loggers;
@@ -156,13 +158,13 @@ public class TxCleanupRecoveryRequestHandler {
                 txMeta.commitTimestamp(),
                 txId
         ).exceptionally(throwable -> {
-            throttledLog.warn(
-                    "Failed to cleanup transaction",
-                    "Failed to cleanup transaction {}.",
-                    throwable,
-                    formatTxInfo(txId, txManager)
-            );
-
+            if (!hasCause(throwable, NodeStoppingException.class) && 
!hasCause(throwable, ComponentStoppingException.class)) {
+                throttledLog.warn(
+                        "Failed to cleanup transaction",
+                        "Failed to cleanup transaction {}.",
+                        throwable,
+                        formatTxInfo(txId, txManager));
+            }
             return null;
         });
     }