(ignite) branch master updated: IGNITE-28869 Fix IgniteWalRebalanceTest.testRebalanceCancelOnSupplyError (#13323)

[av]

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

anton-vinogradov pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git


The following commit(s) were added to refs/heads/master by this push:
     new 1006f74a968 IGNITE-28869 Fix 
IgniteWalRebalanceTest.testRebalanceCancelOnSupplyError (#13323)
1006f74a968 is described below

commit 1006f74a9681c744512cb61cff6e157e42fc3e96
Author: Dmitry Werner <grimekil...@gmail.com>
AuthorDate: Wed Jul 8 16:44:18 2026 +0500

    IGNITE-28869 Fix IgniteWalRebalanceTest.testRebalanceCancelOnSupplyError 
(#13323)
---
 .../cache/persistence/db/wal/IgniteWalRebalanceTest.java   | 14 ++++++++------
 1 file changed, 8 insertions(+), 6 deletions(-)

diff --git 
a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/db/wal/IgniteWalRebalanceTest.java
 
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/db/wal/IgniteWalRebalanceTest.java
index f609473da33..61144f41598 100644
--- 
a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/db/wal/IgniteWalRebalanceTest.java
+++ 
b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/db/wal/IgniteWalRebalanceTest.java
@@ -496,12 +496,11 @@ public class IgniteWalRebalanceTest extends 
GridCommonAbstractTest {
 
         forceCheckpoint();
 
-        stopAllGrids();
+        stopGrid(1);
+        stopGrid(2);
 
         // Rewrite data to trigger further rebalance.
-        IgniteEx supplierNode = startGrid(0);
-
-        supplierNode.cluster().state(ACTIVE);
+        IgniteEx supplierNode = grid(0);
 
         IgniteCache<Object, Object> cache = supplierNode.cache(CACHE_NAME);
 
@@ -532,12 +531,15 @@ public class IgniteWalRebalanceTest extends 
GridCommonAbstractTest {
             getTestTimeout()
         );
 
+        // Hold the demand until the WAL read is armed to fail, so the error 
fires mid-rebalance.
+        TestRecordingCommunicationSpi spi = 
(TestRecordingCommunicationSpi)demanderNode.configuration().getCommunicationSpi();
+
+        spi.waitForBlocked();
+
         // Inject I/O factory which can throw exception during WAL read on 
supplier node.
         FailingIOFactory ioFactory = injectFailingIOFactory(supplierNode);
 
         // Resume rebalance process.
-        TestRecordingCommunicationSpi spi = 
(TestRecordingCommunicationSpi)demanderNode.configuration().getCommunicationSpi();
-
         spi.stopBlock();
 
         // Wait till rebalance will be failed and cancelled.