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 <[email protected]> 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); }
