From beaf28c9891184f9c784814f1da532d8ce90ac2a Mon Sep 17 00:00:00 2001 From: Dmitry Werner Date: Fri, 10 Jul 2026 17:35:43 +0500 Subject: [PATCH 1/2] fix test --- .../persistence/db/wal/IgniteWalRebalanceTest.java | 14 ++++++++++++++ 1 file changed, 14 insertions(+) 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 61144f4159813..4079334ba602a 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 @@ -338,6 +338,13 @@ public void testWithLocalWalChange() throws Exception { awaitPartitionMapExchange(); + // Wait for rebalance to complete on all nodes (don't enforce success — it may switch to full rebalance). + for (Ignite ig : G.allGrids()) { + assertTrue(GridTestUtils.waitForCondition( + () -> ((IgniteEx) ig).cachex(CACHE_NAME).context().preloader().rebalanceFuture().isDone(), + getTestTimeout())); + } + Set topVers = ((WalRebalanceCheckingCommunicationSpi)ignite.configuration().getCommunicationSpi()) .walRebalanceVersions(grpId); @@ -364,6 +371,13 @@ else if (k % 3 == 1) // Spread removes across all partitions. awaitPartitionMapExchange(); + // Wait for rebalance to complete on all nodes (don't enforce success — it may switch to full rebalance). + for (Ignite ig : G.allGrids()) { + assertTrue(GridTestUtils.waitForCondition( + () -> ((IgniteEx) ig).cachex(CACHE_NAME).context().preloader().rebalanceFuture().isDone(), + getTestTimeout())); + } + topVers = ((WalRebalanceCheckingCommunicationSpi)ignite.configuration().getCommunicationSpi()) .walRebalanceVersions(grpId); From f7a9a6b2593e63a56b3bf2498eb75ba6979c2dc8 Mon Sep 17 00:00:00 2001 From: Dmitry Werner Date: Fri, 10 Jul 2026 20:53:54 +0500 Subject: [PATCH 2/2] fix checkstyle --- .../cache/persistence/db/wal/IgniteWalRebalanceTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 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 4079334ba602a..273a8cfb06efc 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 @@ -341,7 +341,7 @@ public void testWithLocalWalChange() throws Exception { // Wait for rebalance to complete on all nodes (don't enforce success — it may switch to full rebalance). for (Ignite ig : G.allGrids()) { assertTrue(GridTestUtils.waitForCondition( - () -> ((IgniteEx) ig).cachex(CACHE_NAME).context().preloader().rebalanceFuture().isDone(), + () -> ((IgniteEx)ig).cachex(CACHE_NAME).context().preloader().rebalanceFuture().isDone(), getTestTimeout())); } @@ -374,7 +374,7 @@ else if (k % 3 == 1) // Spread removes across all partitions. // Wait for rebalance to complete on all nodes (don't enforce success — it may switch to full rebalance). for (Ignite ig : G.allGrids()) { assertTrue(GridTestUtils.waitForCondition( - () -> ((IgniteEx) ig).cachex(CACHE_NAME).context().preloader().rebalanceFuture().isDone(), + () -> ((IgniteEx)ig).cachex(CACHE_NAME).context().preloader().rebalanceFuture().isDone(), getTestTimeout())); }