(ignite-3) branch main updated: IGNITE-27165 Increase timeouts in ThrottlingTest (#7069)

[ibessonov]

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

ibessonov 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 e4567b622d4 IGNITE-27165 Increase timeouts in ThrottlingTest (#7069)
e4567b622d4 is described below

commit e4567b622d4abf89843203c2203960cc9ae3a1d7
Author: Ivan Bessonov <bessonov...@gmail.com>
AuthorDate: Wed Nov 26 12:38:18 2025 +0300

    IGNITE-27165 Increase timeouts in ThrottlingTest (#7069)
---
 .../pagememory/persistence/throttling/ThrottlingTest.java     | 11 ++++++++---
 1 file changed, 8 insertions(+), 3 deletions(-)

diff --git 
a/modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/persistence/throttling/ThrottlingTest.java
 
b/modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/persistence/throttling/ThrottlingTest.java
index e09c2a48349..30b224444d9 100644
--- 
a/modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/persistence/throttling/ThrottlingTest.java
+++ 
b/modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/persistence/throttling/ThrottlingTest.java
@@ -20,10 +20,11 @@ package 
org.apache.ignite.internal.pagememory.persistence.throttling;
 import static java.lang.Thread.State.TIMED_WAITING;
 import static 
org.apache.ignite.internal.pagememory.persistence.throttling.PagesWriteSpeedBasedThrottle.DEFAULT_MAX_DIRTY_PAGES;
 import static 
org.apache.ignite.internal.pagememory.persistence.throttling.PagesWriteSpeedBasedThrottle.DEFAULT_MIN_RATIO_NO_THROTTLE;
-import static 
org.apache.ignite.internal.testframework.IgniteTestUtils.waitForCondition;
+import static org.awaitility.Awaitility.await;
 import static org.hamcrest.MatcherAssert.assertThat;
 import static org.hamcrest.Matchers.greaterThan;
 import static org.hamcrest.Matchers.is;
+import static org.hamcrest.Matchers.not;
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertNotEquals;
 import static org.junit.jupiter.api.Assertions.assertTrue;
@@ -258,7 +259,7 @@ public class ThrottlingTest extends IgniteAbstractTest {
 
             // And: All load threads are parked.
             for (Thread t : loadThreads) {
-                assertTrue(waitForCondition(() -> t.getState() == 
TIMED_WAITING, 1000L), t.getName());
+                await().timeout(5, TimeUnit.SECONDS).until(t::getState, 
is(TIMED_WAITING));
             }
 
             // When: Disable throttling
@@ -271,7 +272,7 @@ public class ThrottlingTest extends IgniteAbstractTest {
 
             // Then: All load threads should be unparked.
             for (Thread t : loadThreads) {
-                assertTrue(waitForCondition(() -> t.getState() != 
TIMED_WAITING, 500L), t.getName());
+                await().timeout(5, TimeUnit.SECONDS).until(t::getState, 
is(not(TIMED_WAITING)));
             }
 
             for (Thread t : loadThreads) {
@@ -279,6 +280,10 @@ public class ThrottlingTest extends IgniteAbstractTest {
             }
         } finally {
             stopLoad.set(true);
+
+            for (Thread t : loadThreads) {
+                t.join();
+            }
         }
     }