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