You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by as...@apache.org on 2026/04/10 13:36:07 UTC
(ignite-3) branch main updated: IGNITE-28508 Fixed flaky MultiActorPlacementDriverTest.prolongAfterActiveActorChanged (#7971)
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 <mo...@gmail.com>
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