(ignite) branch master updated: IGNITE-28092 Fixed flaky IndexQueryPaginationTest#nextPageTest test (#12868)

[namelchev]

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

namelchev 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 49880f1c8dd IGNITE-28092 Fixed flaky 
IndexQueryPaginationTest#nextPageTest test (#12868)
49880f1c8dd is described below

commit 49880f1c8ddd1553b06feb4941609f36bfa24e07
Author: Nikita Amelchev <nsamelc...@gmail.com>
AuthorDate: Fri Mar 6 16:01:09 2026 +0300

    IGNITE-28092 Fixed flaky IndexQueryPaginationTest#nextPageTest test (#12868)
---
 .../cache/query/IndexQueryPaginationTest.java      | 22 +++++++++++-----------
 .../cache/query/MultifieldIndexQueryTest.java      |  2 ++
 2 files changed, 13 insertions(+), 11 deletions(-)

diff --git 
a/modules/indexing/src/test/java/org/apache/ignite/cache/query/IndexQueryPaginationTest.java
 
b/modules/indexing/src/test/java/org/apache/ignite/cache/query/IndexQueryPaginationTest.java
index 1e20a7b5b67..a4102d4fd98 100644
--- 
a/modules/indexing/src/test/java/org/apache/ignite/cache/query/IndexQueryPaginationTest.java
+++ 
b/modules/indexing/src/test/java/org/apache/ignite/cache/query/IndexQueryPaginationTest.java
@@ -46,9 +46,6 @@ public class IndexQueryPaginationTest extends 
GridCommonAbstractTest {
     /** */
     private static final int NODES = 2;
 
-    /** */
-    private Ignite grid;
-
     /** */
     private IgniteCache<Integer, Person> cache;
 
@@ -64,11 +61,13 @@ public class IndexQueryPaginationTest extends 
GridCommonAbstractTest {
 
     /** {@inheritDoc} */
     @Override protected void beforeTest() throws Exception {
-        grid = startGrids(NODES);
+        Ignite srv = startGrids(NODES);
+
+        cache = srv.cache("cache");
 
-        cache = grid.cache("cache");
+        awaitPartitionMapExchange();
 
-        insertData(grid, cache, entries);
+        insertData(srv, cache, entries);
     }
 
     /** {@inheritDoc} */
@@ -119,7 +118,7 @@ public class IndexQueryPaginationTest extends 
GridCommonAbstractTest {
         QueryCursor<Cache.Entry<Integer, Person>> cursor = cache.query(
             new IndexQuery<Integer, 
Person>(Person.class).setPageSize(PAGE_SIZE));
 
-        assert entries == cursor.getAll().size();
+        assertEquals(entries, cursor.getAll().size());
 
         List<Object> msgs = new ArrayList<>();
 
@@ -131,18 +130,19 @@ public class IndexQueryPaginationTest extends 
GridCommonAbstractTest {
 
         int reqsSize = reqs.size();
 
-        assert reqsSize == reqsExpected && reqsSize == resp.size();
+        assertEquals(reqsExpected, reqsSize);
+        assertEquals(reqsSize, resp.size());
 
         for (int i = 0; i < reqsSize; i++) {
             int reqPage = reqs.get(i).pageSize();
             int respData = resp.get(i).data().size();
 
-            assert reqPage == PAGE_SIZE;
+            assertEquals(PAGE_SIZE, reqPage);
 
             if (i == reqsSize - 1 && remNodeLastPageEntries != 0)
-                assert respData == remNodeLastPageEntries;
+                assertEquals(remNodeLastPageEntries, respData);
             else
-                assert respData == reqPage;
+                assertEquals(respData, reqPage);
         }
     }
 
diff --git 
a/modules/indexing/src/test/java/org/apache/ignite/cache/query/MultifieldIndexQueryTest.java
 
b/modules/indexing/src/test/java/org/apache/ignite/cache/query/MultifieldIndexQueryTest.java
index 5f08e589ec2..5e3c46f643b 100644
--- 
a/modules/indexing/src/test/java/org/apache/ignite/cache/query/MultifieldIndexQueryTest.java
+++ 
b/modules/indexing/src/test/java/org/apache/ignite/cache/query/MultifieldIndexQueryTest.java
@@ -103,6 +103,8 @@ public class MultifieldIndexQueryTest extends 
GridCommonAbstractTest {
         ignite = startGrids(nodesCnt);
 
         cache = ignite.cache(CACHE);
+
+        awaitPartitionMapExchange();
     }
 
     /** {@inheritDoc} */