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

rpuch 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 675f0fee462 IGNITE-27103 Don't call failure handler for Handshake 
exception in IncomingSnapshotCopier joinFuture (#7015)
675f0fee462 is described below

commit 675f0fee462228c009f162e1174a697c4caee291
Author: Phillippko <[email protected]>
AuthorDate: Thu Nov 20 11:24:50 2025 +0400

    IGNITE-27103 Don't call failure handler for Handshake exception in 
IncomingSnapshotCopier joinFuture (#7015)
---
 .../replicator/raft/snapshot/incoming/IncomingSnapshotCopier.java   | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git 
a/modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/incoming/IncomingSnapshotCopier.java
 
b/modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/incoming/IncomingSnapshotCopier.java
index 42f2e6326a0..768cf64ead4 100644
--- 
a/modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/incoming/IncomingSnapshotCopier.java
+++ 
b/modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/incoming/IncomingSnapshotCopier.java
@@ -51,6 +51,7 @@ import org.apache.ignite.internal.logger.Loggers;
 import org.apache.ignite.internal.lowwatermark.message.GetLowWatermarkResponse;
 import 
org.apache.ignite.internal.lowwatermark.message.LowWatermarkMessagesFactory;
 import org.apache.ignite.internal.network.InternalClusterNode;
+import org.apache.ignite.internal.network.handshake.HandshakeException;
 import 
org.apache.ignite.internal.partition.replicator.network.PartitionReplicationMessagesFactory;
 import 
org.apache.ignite.internal.partition.replicator.network.raft.PartitionSnapshotMeta;
 import 
org.apache.ignite.internal.partition.replicator.network.raft.SnapshotMetaResponse;
@@ -238,7 +239,10 @@ public class IncomingSnapshotCopier extends SnapshotCopier 
{
                 Throwable cause = e.getCause();
 
                 if (!(cause instanceof CancellationException)) {
-                    partitionSnapshotStorage.failureProcessor().process(new 
FailureContext(e, "Error when completing the copier"));
+                    // TODO https://issues.apache.org/jira/browse/IGNITE-26811 
HandshakeException is thrown when node is stopping.
+                    if (!(cause instanceof HandshakeException)) {
+                        
partitionSnapshotStorage.failureProcessor().process(new FailureContext(e, 
"Error when completing the copier"));
+                    }
 
                     if (isOk()) {
                         setError(RaftError.UNKNOWN, "Unknown error on 
completion the copier");

Reply via email to