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 38c03aadfa7 IGNITE-25398 Handle RecipientLeftException in
topology-aware raft client (#5828)
38c03aadfa7 is described below
commit 38c03aadfa7cdd689ea8ce78fa5b6c16e65f96c5
Author: Roman Puchkovskiy <roman.puchkovs...@gmail.com>
AuthorDate: Fri May 16 15:42:50 2025 +0400
IGNITE-25398 Handle RecipientLeftException in topology-aware raft client
(#5828)
---
.../ignite/internal/raft/client/TopologyAwareRaftGroupService.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/modules/replicator/src/main/java/org/apache/ignite/internal/raft/client/TopologyAwareRaftGroupService.java
b/modules/replicator/src/main/java/org/apache/ignite/internal/raft/client/TopologyAwareRaftGroupService.java
index 218f99dbb6f..e9e9eac8912 100644
---
a/modules/replicator/src/main/java/org/apache/ignite/internal/raft/client/TopologyAwareRaftGroupService.java
+++
b/modules/replicator/src/main/java/org/apache/ignite/internal/raft/client/TopologyAwareRaftGroupService.java
@@ -40,6 +40,7 @@ import org.apache.ignite.internal.lang.NodeStoppingException;
import org.apache.ignite.internal.logger.IgniteLogger;
import org.apache.ignite.internal.logger.Loggers;
import org.apache.ignite.internal.network.ClusterService;
+import org.apache.ignite.internal.network.RecipientLeftException;
import org.apache.ignite.internal.raft.Command;
import org.apache.ignite.internal.raft.ExceptionFactory;
import org.apache.ignite.internal.raft.LeaderElectionListener;
@@ -309,7 +310,7 @@ public class TopologyAwareRaftGroupService implements
RaftGroupService {
t = t.getCause();
}
- return t instanceof TimeoutException || t instanceof IOException;
+ return t instanceof TimeoutException || t instanceof IOException || t
instanceof RecipientLeftException;
}
/**
