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

alexpl 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 c2bcbc49778 IGNITE-27750 SQL Calcite: Fix flaky 
PartitionsReservationIntegrationTest - Fixes #12700.
c2bcbc49778 is described below

commit c2bcbc49778dacfe03fdbf525b17485dd7393f38
Author: Aleksey Plekhanov <[email protected]>
AuthorDate: Fri Feb 6 10:02:46 2026 +0300

    IGNITE-27750 SQL Calcite: Fix flaky PartitionsReservationIntegrationTest - 
Fixes #12700.
    
    Signed-off-by: Aleksey Plekhanov <[email protected]>
---
 .../PartitionsReservationIntegrationTest.java          | 18 ++++++++++++++----
 1 file changed, 14 insertions(+), 4 deletions(-)

diff --git 
a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/PartitionsReservationIntegrationTest.java
 
b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/PartitionsReservationIntegrationTest.java
index 242fe33b596..cf4314a439d 100644
--- 
a/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/PartitionsReservationIntegrationTest.java
+++ 
b/modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/PartitionsReservationIntegrationTest.java
@@ -18,6 +18,7 @@
 package org.apache.ignite.internal.processors.query.calcite.integration;
 
 import java.util.concurrent.atomic.AtomicBoolean;
+import org.apache.ignite.Ignite;
 import org.apache.ignite.IgniteDataStreamer;
 import org.apache.ignite.cache.affinity.rendezvous.RendezvousAffinityFunction;
 import org.apache.ignite.cluster.ClusterTopologyException;
@@ -30,6 +31,8 @@ import 
org.apache.ignite.internal.processors.query.calcite.QueryChecker;
 import org.apache.ignite.internal.processors.query.calcite.exec.IndexScan;
 import org.apache.ignite.internal.processors.query.calcite.exec.TableScan;
 import 
org.apache.ignite.internal.processors.query.calcite.rel.IgniteIndexCount;
+import 
org.apache.ignite.internal.processors.query.calcite.schema.IgniteCacheTable;
+import org.apache.ignite.internal.util.typedef.G;
 import org.apache.ignite.internal.util.typedef.X;
 import org.junit.Test;
 
@@ -88,18 +91,25 @@ public class PartitionsReservationIntegrationTest extends 
AbstractBasicIntegrati
     @Test
     public void testIndexScan() throws Exception {
         checkPartitionsReservationRelease(
-            assertQuery("SELECT /*+ FORCE_INDEX */ * FROM Employer")
+            assertQuery("SELECT /*+ FORCE_INDEX */ * FROM Employer WHERE 
salary::int % 100 = 0")
                 
.matches(QueryChecker.containsSubPlan(IndexScan.class.getSimpleName()))
-                .resultSize(KEYS));
+                .resultSize(KEYS / 100));
     }
 
     /** */
     @Test
     public void testTableScan() throws Exception {
+        for (Ignite grid : G.allGrids()) {
+            IgniteCacheTable tbl = 
(IgniteCacheTable)queryProcessor(grid).schemaHolder()
+                .schema("PUBLIC").tables().get("EMPLOYER");
+
+            tbl.markIndexRebuildInProgress(true);
+        }
+
         checkPartitionsReservationRelease(
-            assertQuery("SELECT * FROM Employer")
+            assertQuery("SELECT * FROM Employer WHERE salary::int % 100 = 0")
                 
.matches(QueryChecker.containsSubPlan(TableScan.class.getSimpleName()))
-                .resultSize(KEYS));
+                .resultSize(KEYS / 100));
     }
 
     /** */

Reply via email to