You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vp...@apache.org on 2023/11/22 13:14:55 UTC
(ignite-3) branch ignite-20918 created (now 5714577436)
This is an automated email from the ASF dual-hosted git repository.
vpyatkov pushed a change to branch ignite-20918
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
at 5714577436 IGNITE-20918 Leases expire after a node has been restarted
This branch includes the following new commits:
new 5714577436 IGNITE-20918 Leases expire after a node has been restarted
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-20918 Leases expire after a node has been restarted
Posted by vp...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
vpyatkov pushed a commit to branch ignite-20918
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit 5714577436833f696ab0c09f87f89d4c9b9b3575
Author: Vladislav Pyatkov <vl...@gmail.com>
AuthorDate: Wed Nov 22 16:14:27 2023 +0300
IGNITE-20918 Leases expire after a node has been restarted
---
.../internal/table/distributed/replicator/PartitionReplicaListener.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java b/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
index 2318f6081b..5250ad64cb 100644
--- a/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
+++ b/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
@@ -420,7 +420,7 @@ public class PartitionReplicaListener implements ReplicaListener {
}
private CompletableFuture<Boolean> onPrimaryExpired(PrimaryReplicaEventParameters evt, @Nullable Throwable exception) {
- if (!localNode.name().equals(evt.leaseholder())) {
+ if (!localNode.name().equals(evt.leaseholder()) || !replicationGroupId.equals(evt.groupId())) {
return completedFuture(false);
}