(ignite-3) branch main updated: IGNITE-20942 Group equality check added for PartitionReplicaListener scoped PR events (#2876)

[sanpwc]

This is an automated email from the ASF dual-hosted git repository.

sanpwc 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 7f4aa84333 IGNITE-20942 Group equality check added for 
PartitionReplicaListener scoped PR events (#2876)
7f4aa84333 is described below

commit 7f4aa8433321a2d513eaa9409f3a2245f955ff72
Author: Alexander Lapin <lapin1...@gmail.com>
AuthorDate: Fri Nov 24 17:36:24 2023 +0200

    IGNITE-20942 Group equality check added for PartitionReplicaListener scoped 
PR events (#2876)
---
 .../table/distributed/replicator/PartitionReplicaListener.java        | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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..543967ff77 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
@@ -343,7 +343,7 @@ public class PartitionReplicaListener implements 
ReplicaListener {
     }
 
     private CompletableFuture<Boolean> 
onPrimaryElected(PrimaryReplicaEventParameters evt, @Nullable Throwable 
exception) {
-        if (!localNode.name().equals(evt.leaseholder())) {
+        if (!localNode.name().equals(evt.leaseholder()) || 
!replicationGroupId.equals(evt.groupId())) {
             return completedFuture(false);
         }
 
@@ -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);
         }