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

ashapkin 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 27d77bd7c71 IGNITE-28508 Fixed flaky 
MultiActorPlacementDriverTest.prolongAfterActiveActorChanged (#7971)
27d77bd7c71 is described below

commit 27d77bd7c7137531ac23caa30588ad875c8a3500
Author: Denis Chudov <[email protected]>
AuthorDate: Fri Apr 10 16:36:01 2026 +0300

    IGNITE-28508 Fixed flaky 
MultiActorPlacementDriverTest.prolongAfterActiveActorChanged (#7971)
---
 .../internal/placementdriver/MultiActorPlacementDriverTest.java  | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git 
a/modules/placement-driver/src/integrationTest/java/org/apache/ignite/internal/placementdriver/MultiActorPlacementDriverTest.java
 
b/modules/placement-driver/src/integrationTest/java/org/apache/ignite/internal/placementdriver/MultiActorPlacementDriverTest.java
index 92f3a24b8aa..6fcb399f610 100644
--- 
a/modules/placement-driver/src/integrationTest/java/org/apache/ignite/internal/placementdriver/MultiActorPlacementDriverTest.java
+++ 
b/modules/placement-driver/src/integrationTest/java/org/apache/ignite/internal/placementdriver/MultiActorPlacementDriverTest.java
@@ -83,6 +83,7 @@ import 
org.apache.ignite.internal.raft.RaftGroupOptionsConfigurer;
 import org.apache.ignite.internal.raft.TestLozaFactory;
 import 
org.apache.ignite.internal.raft.client.TopologyAwareRaftGroupServiceFactory;
 import org.apache.ignite.internal.raft.configuration.RaftConfiguration;
+import org.apache.ignite.internal.raft.service.LeaderWithTerm;
 import org.apache.ignite.internal.raft.service.TimeAwareRaftGroupService;
 import org.apache.ignite.internal.raft.storage.LogStorageManager;
 import org.apache.ignite.internal.raft.util.SharedLogStorageManagerUtils;
@@ -420,9 +421,13 @@ public class MultiActorPlacementDriverTest extends 
BasePlacementDriverTest {
 
         waitForProlong(grpPart0, lease);
 
-        
assertThat(msRaftClient.refreshLeader(TimeAwareRaftGroupService.NO_TIMEOUT), 
willCompleteSuccessfully());
+        CompletableFuture<LeaderWithTerm> actualLeaderFut = 
msRaftClient.refreshAndGetLeaderWithTerm(TimeAwareRaftGroupService.NO_TIMEOUT);
+
+        assertThat(actualLeaderFut, willCompleteSuccessfully());
+
+        Peer actualLeader = actualLeaderFut.join().leader();
 
-        assertEquals(newLeader, msRaftClient.leader());
+        assertEquals(newLeader, actualLeader);
     }
 
     @Test

Reply via email to