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");