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));
}
/** */