Skip to content

Commit 16414f4

Browse files
committed
Add more logging in attempt to figure out what's messing up this test
1 parent a7a79f7 commit 16414f4

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

muted-tests.yml

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -224,9 +224,6 @@ tests:
224224
- class: org.elasticsearch.packaging.test.BootstrapCheckTests
225225
method: test20RunWithBootstrapChecks
226226
issue: https://github.com/elastic/elasticsearch/issues/124940
227-
- class: org.elasticsearch.xpack.esql.action.CrossClusterAsyncQueryStopIT
228-
method: testStopQueryLocal
229-
issue: https://github.com/elastic/elasticsearch/issues/121672
230227
- class: org.elasticsearch.packaging.test.BootstrapCheckTests
231228
method: test10Install
232229
issue: https://github.com/elastic/elasticsearch/issues/124957

x-pack/plugin/esql/src/internalClusterTest/java/org/elasticsearch/xpack/esql/action/CrossClusterAsyncQueryStopIT.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -133,6 +133,7 @@ public void testStopQueryLocal() throws Exception {
133133
Tuple<Boolean, Boolean> includeCCSMetadata = randomIncludeCCSMetadata();
134134
boolean responseExpectMeta = includeCCSMetadata.v2();
135135

136+
LOGGER.info("Launching async query");
136137
final String asyncExecutionId = startAsyncQuery(
137138
client(),
138139
"FROM blocking,*:logs-* | STATS total=sum(coalesce(const,v)) | LIMIT 1",
@@ -141,11 +142,15 @@ public void testStopQueryLocal() throws Exception {
141142

142143
try {
143144
// wait until we know that the local query against 'blocking' has started
145+
LOGGER.info("Waiting for {} to start", asyncExecutionId);
144146
assertTrue(SimplePauseFieldPlugin.startEmitting.await(30, TimeUnit.SECONDS));
145147

146148
// wait until the remotes are done
149+
LOGGER.info("Waiting for remotes", asyncExecutionId);
147150
waitForCluster(client(), REMOTE_CLUSTER_1, asyncExecutionId);
151+
LOGGER.info("Remote 1 done", asyncExecutionId);
148152
waitForCluster(client(), REMOTE_CLUSTER_2, asyncExecutionId);
153+
LOGGER.info("Remote 2 done", asyncExecutionId);
149154

150155
/* at this point:
151156
* the query against remotes should be finished

0 commit comments

Comments
 (0)