You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by rp...@apache.org on 2025/11/20 07:24:55 UTC
(ignite-3) branch main updated: IGNITE-27103 Don't call failure handler for Handshake exception in IncomingSnapshotCopier joinFuture (#7015)
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 <ph...@gmail.com>
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");