Skip to content

Commit f9d3934

Browse files
authored
Add more logging in attempt to figure out what's messing up this test (#130516)
1 parent cdfd3dd commit f9d3934

File tree

2 files changed

+7
-5
lines changed

2 files changed

+7
-5
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: 7 additions & 2 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
@@ -159,14 +164,14 @@ public void testStopQueryLocal() throws Exception {
159164
assertBusy(() -> {
160165
try (EsqlQueryResponse asyncResponse = getAsyncResponse(client(), asyncExecutionId)) {
161166
EsqlExecutionInfo executionInfo = asyncResponse.getExecutionInfo();
162-
LOGGER.info("Waiting for stop operation to start, current status: {}", executionInfo);
167+
LOGGER.info("--> Waiting for stop operation to start, current status: {}", executionInfo);
163168
assertNotNull(executionInfo);
164169
assertThat(executionInfo.isStopped(), is(true));
165170
}
166171
});
167172
// allow local query to proceed
168173
SimplePauseFieldPlugin.allowEmitting.countDown();
169-
LOGGER.info("Collecting results for {}", asyncExecutionId);
174+
LOGGER.info("--> Collecting results for {}", asyncExecutionId);
170175

171176
// Since part of the query has not been stopped, we expect some result to emerge here
172177
try (EsqlQueryResponse asyncResponse = stopAction.actionGet(30, TimeUnit.SECONDS)) {

0 commit comments

Comments
 (0)