IGNITE-23982 Comment out asserts on primary elected/expired in Replic…

…aStateManager (#4893)
apache · Dec 13, 2024 · b72cbcc · b72cbcc
1 parent f5c0169
commit b72cbcc
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/modules/replicator/src/main/java/org/apache/ignite/internal/replicator/ReplicaManager.java b/modules/replicator/src/main/java/org/apache/ignite/internal/replicator/ReplicaManager.java
@@ -1367,8 +1367,9 @@ private void registerFailoverCallback(ReplicationGroupId replicationGroupId) {
                 return;
             }
 
-            assert replicaFuture.isDone() : "Illegal state: replica future exists and elected as primary, but the future isn't completed"
-                    + " [replicationGroupId=" + replicaFuture + "].";
+            // TODO: https://issues.apache.org/jira/browse/IGNITE-23981
+            // assert replicaFuture.isDone() : "Illegal state: replica future exists and elected as primary, but the future isn't completed"
+            //         + " [replicationGroupId=" + replicaFuture + "].";
 
             replicaFuture.thenCompose(inBusyLock(busyLock, () -> (Function<Replica, CompletableFuture<Void>>) electedPrimaryReplica -> {
                 onLeaderElectedFailoverCallback = (leaderNode, term) -> changePeersAndLearnersAsyncIfPendingExists(
@@ -1398,8 +1399,9 @@ private void unregisterFailoverCallback(PrimaryReplicaEventParameters parameters
                 return;
             }
 
-            assert replicaFuture.isDone() : "Illegal state: replica future exists and was elected as primary, but the future isn't"
-                    + " completed [replicationGroupId=" + replicaFuture + "].";
+            // TODO: https://issues.apache.org/jira/browse/IGNITE-23981
+            // assert replicaFuture.isDone() : "Illegal state: replica future exists and was elected as primary, but the future isn't"
+            //         + " completed [replicationGroupId=" + replicaFuture + "].";
 
             replicaFuture.thenAccept(inBusyLock(busyLock, () -> (Consumer<Replica>) expiredPrimaryReplica -> expiredPrimaryReplica
                     .raftClient()