Add more logging around testStopQueryLocal to see what's going on (elastic#124911) (elastic#124932)

(cherry picked from commit aa2db74)

# Conflicts:
#	muted-tests.yml

Author: smalyshev

muted-tests.yml

@@ -426,9 +426,6 @@ tests:
 - class: org.elasticsearch.ingest.geoip.GeoIpDownloaderCliIT
   method: testGeoIpDatabasesDownloadNoGeoipProcessors
   issue: https://github.com/elastic/elasticsearch/issues/122683
-- class: org.elasticsearch.xpack.esql.action.CrossClusterAsyncQueryStopIT
-  method: testStopQueryLocal
-  issue: https://github.com/elastic/elasticsearch/issues/121672
 - class: org.elasticsearch.xpack.test.rest.XPackRestIT
   method: test {p0=snapshot/10_basic/Create a source only snapshot and then restore it}
   issue: https://github.com/elastic/elasticsearch/issues/122755

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

@@ -10,6 +10,8 @@
 import org.elasticsearch.Build;
 import org.elasticsearch.action.ActionFuture;
 import org.elasticsearch.core.Tuple;
+import org.elasticsearch.logging.LogManager;
+import org.elasticsearch.logging.Logger;
 import org.elasticsearch.tasks.TaskInfo;
 import org.elasticsearch.xpack.core.async.AsyncStopRequest;
 
@@ -34,6 +36,8 @@
 
 public class CrossClusterAsyncQueryStopIT extends AbstractCrossClusterTestCase {
 
+    private static final Logger LOGGER = LogManager.getLogger(CrossClusterAsyncQueryStopIT.class);
+
     public void testStopQuery() throws Exception {
         assumeTrue("Pragma does not work in release builds", Build.current().isSnapshot());
         Map<String, Object> testClusterInfo = setupClusters(3);
@@ -136,8 +140,8 @@ public void testStopQueryLocal() throws Exception {
         );
 
         try {
-            // wait until we know that the query against 'remote-b:blocking' has started
-            SimplePauseFieldPlugin.startEmitting.await(30, TimeUnit.SECONDS);
+            // wait until we know that the local query against 'blocking' has started
+            assertTrue(SimplePauseFieldPlugin.startEmitting.await(30, TimeUnit.SECONDS));
 
             // wait until the remotes are done
             waitForCluster(client(), REMOTE_CLUSTER_1, asyncExecutionId);
@@ -147,20 +151,22 @@ public void testStopQueryLocal() throws Exception {
              *  the query against remotes should be finished
              *  the query against the local cluster should be running because it's blocked
              */
-
             // run the stop query
             AsyncStopRequest stopRequest = new AsyncStopRequest(asyncExecutionId);
+            LOGGER.info("Launching stop for {}", asyncExecutionId);
             ActionFuture<EsqlQueryResponse> stopAction = client().execute(EsqlAsyncStopAction.INSTANCE, stopRequest);
             // ensure stop operation is running
             assertBusy(() -> {
                 try (EsqlQueryResponse asyncResponse = getAsyncResponse(client(), asyncExecutionId)) {
                     EsqlExecutionInfo executionInfo = asyncResponse.getExecutionInfo();
+                    LOGGER.info("Waiting for stop operation to start, current status: {}", executionInfo);
                     assertNotNull(executionInfo);
                     assertThat(executionInfo.isStopped(), is(true));
                 }
             });
             // allow local query to proceed
             SimplePauseFieldPlugin.allowEmitting.countDown();
+            LOGGER.info("Collecting results for {}", asyncExecutionId);
 
             // Since part of the query has not been stopped, we expect some result to emerge here
             try (EsqlQueryResponse asyncResponse = stopAction.actionGet(30, TimeUnit.SECONDS)) {
@@ -204,7 +210,6 @@ public void testStopQueryLocalNoRemotes() throws Exception {
         populateRuntimeIndex(LOCAL_CLUSTER, "pause", INDEX_WITH_BLOCKING_MAPPING);
 
         Tuple<Boolean, Boolean> includeCCSMetadata = randomIncludeCCSMetadata();
-        boolean responseExpectMeta = includeCCSMetadata.v2();
 
         final String asyncExecutionId = startAsyncQuery(
             client(),

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/action/EsqlExecutionInfo.java

@@ -302,7 +302,16 @@ public int getClusterStateCount(Cluster.Status status) {
 
     @Override
     public String toString() {
-        return "EsqlExecutionInfo{" + "overallTook=" + overallTook + ", clusterInfo=" + clusterInfo + '}';
+        return "EsqlExecutionInfo{"
+            + "overallTook="
+            + overallTook
+            + ", isPartial="
+            + isPartial
+            + ", isStopped="
+            + isStopped
+            + ", clusterInfo="
+            + clusterInfo
+            + '}';
     }
 
     @Override