(ignite-3) branch main updated: IGNITE-28086 Fix flaky test testHaWhenAllVotingMembersAreLost (#7721)

[ashapkin]

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 a11fb08638c IGNITE-28086 Fix flaky test 
testHaWhenAllVotingMembersAreLost (#7721)
a11fb08638c is described below

commit a11fb08638cb6a6eeb22100e6ebb3693b1358e84
Author: Cyrill <cyrill.si...@gmail.com>
AuthorDate: Thu Apr 2 10:42:10 2026 +0300

    IGNITE-28086 Fix flaky test testHaWhenAllVotingMembersAreLost (#7721)
    
    Co-authored-by: Kirill Sizov <sizov.kiril...@gmail.com>
---
 .../ItHighAvailablePartitionsRecoveryByFilterUpdateTest.java        | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git 
a/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryByFilterUpdateTest.java
 
b/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryByFilterUpdateTest.java
index 773f5610b67..582bee31800 100644
--- 
a/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryByFilterUpdateTest.java
+++ 
b/modules/table/src/integrationTest/java/org/apache/ignite/internal/table/distributed/disaster/ItHighAvailablePartitionsRecoveryByFilterUpdateTest.java
@@ -509,6 +509,9 @@ public class 
ItHighAvailablePartitionsRecoveryByFilterUpdateTest extends Abstrac
 
         assertEquals(3, followers.size());
 
+        // Set a high timeout to prevent multiple recovery events from firing 
when followers leave topology one by one.
+        changePartitionDistributionTimeout(node0, (int) 
TimeUnit.MINUTES.toSeconds(5));
+
         // Stop all followers.
         followers.forEach(n -> stopNode(n.consistentId()));
 
@@ -519,6 +522,9 @@ public class 
ItHighAvailablePartitionsRecoveryByFilterUpdateTest extends Abstrac
 
         IgniteImpl node = igniteImpl(nodeIndex(learners.iterator().next()));
 
+        // Trigger a single recovery event by setting timeout to 0.
+        changePartitionDistributionTimeout(node0, 0);
+
         // Wait for the partition to become available on the learners.
         waitAndAssertStableAssignmentsOfPartitionEqualTo(node, HA_TABLE_NAME, 
Set.of(0), learners);
     }