You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by tk...@apache.org on 2025/07/16 08:41:21 UTC
(ignite-3) branch ignite-25925 created (now 65ad1a559e4)
This is an automated email from the ASF dual-hosted git repository.
tkalkirill pushed a change to branch ignite-25925
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
at 65ad1a559e4 IGNITE-25925 wip
This branch includes the following new commits:
new 65ad1a559e4 IGNITE-25925 wip
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
(ignite-3) 01/01: IGNITE-25925 wip
Posted by tk...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
tkalkirill pushed a commit to branch ignite-25925
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit 65ad1a559e44feac45dae212672f8032ec259d0c
Author: Kirill Tkalenko <tk...@yandex.ru>
AuthorDate: Wed Jul 16 11:41:04 2025 +0300
IGNITE-25925 wip
---
.../partition/replicator/PartitionReplicaLifecycleManager.java | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
diff --git a/modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/PartitionReplicaLifecycleManager.java b/modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/PartitionReplicaLifecycleManager.java
index 1d7f831fd1d..09a7f47088c 100644
--- a/modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/PartitionReplicaLifecycleManager.java
+++ b/modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/PartitionReplicaLifecycleManager.java
@@ -1437,13 +1437,12 @@ public class PartitionReplicaLifecycleManager extends
"Node couldn't get the leader within timeout so the changing peers is skipped [grp={}].",
replicaGrpId
);
- }
- if (hasCause(throwable, ComponentStoppingException.class)) {
+ } else if (hasCause(throwable, ComponentStoppingException.class)) {
LOG.info("Replica is being stopped so the changing peers is skipped [grp={}].", replicaGrpId);
+ } else {
+ LOG.info("Failed to get a leader for the RAFT replication group [grp={}].", throwable, replicaGrpId);
}
- LOG.info("Failed to get a leader for the RAFT replication group [grp={}].", throwable, replicaGrpId);
-
return LeaderWithTerm.NO_LEADER;
})
.thenCompose(leaderWithTerm -> {