Skip to content

IGNITE-28707 Fix flaky IndexScanlIntegrationTest.testForcedIndexHint and near #13164

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
zstan wants to merge 3 commits into
base: master
Choose a base branch
from
Open

IGNITE-28707 Fix flaky IndexScanlIntegrationTest.testForcedIndexHint and near #13164

Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
ecd6aea
IGNITE-28707 Fix flaky IndexScanlIntegrationTest.testForcedIndexHint …
zstan May 20, 2026
d76a45b
fix
zstan May 21, 2026
a880ae3
fix
zstan May 21, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
34 changes: 32 additions & 2 deletions ...he/ignite/internal/processors/query/calcite/integration/AbstractBasicIntegrationTest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,8 @@

package org.apache.ignite.internal.processors.query.calcite.integration;

import java.util.ArrayList;
import java.util.Collection;
import java.util.Collections;
import java.util.List;
import org.apache.calcite.plan.RelOptCluster;
Expand All @@ -36,11 +38,14 @@
import org.apache.ignite.internal.processors.query.QueryContext;
import org.apache.ignite.internal.processors.query.QueryEngine;
import org.apache.ignite.internal.processors.query.calcite.CalciteQueryProcessor;
import org.apache.ignite.internal.processors.query.calcite.Query;
import org.apache.ignite.internal.processors.query.calcite.QueryChecker;
import org.apache.ignite.internal.processors.query.calcite.RootQuery;
import org.apache.ignite.internal.processors.query.calcite.exec.ExecutionContext;
import org.apache.ignite.internal.processors.query.calcite.exec.ExecutionServiceImpl;
import org.apache.ignite.internal.processors.query.calcite.exec.exp.RangeIterable;
import org.apache.ignite.internal.processors.query.calcite.metadata.ColocationGroup;
import org.apache.ignite.internal.processors.query.calcite.prepare.PlanningContext;
import org.apache.ignite.internal.processors.query.calcite.prepare.bounds.SearchBounds;
import org.apache.ignite.internal.processors.query.calcite.schema.IgniteIndex;
import org.apache.ignite.internal.processors.query.calcite.schema.IgniteTable;
Expand Down Expand Up @@ -93,8 +98,33 @@ protected boolean destroyCachesAfterTest() {
// Wait for pending queries before destroying caches. If some error occurs during query execution, client code
// can get control earlier than query leave the running queries registry (need some time for async message
// exchange), but eventually, all queries should be closed.
assertTrue("Not finished queries found on client", waitForCondition(
() -> queryProcessor(client).queryRegistry().runningQueries().isEmpty(), 1_000L));
List<Query<?>> runningSnap = new ArrayList<>();

boolean res = waitForCondition(
() -> {
Collection<? extends Query<?>> activeQueries = queryProcessor(client).queryRegistry().runningQueries();

runningSnap.clear();

if (!activeQueries.isEmpty())
runningSnap.addAll(activeQueries);

return activeQueries.isEmpty();
}, 1_000L);

if (!res) {
log.error("Not finished queries found on client: " + runningSnap.size());

for (Query<?> qry : runningSnap) {
if (qry instanceof RootQuery) {
RootQuery<?> root = (RootQuery<?>)qry;
String active = GridTestUtils.getFieldValue(root.planningContext(), PlanningContext.class, "qry");
log.error("Not finished: query=[" + active + ']');
}
}
}

assertTrue(res);

for (Ignite ign : G.allGrids()) {
if (destroyCachesAfterTest()) {
Expand Down
Loading