Fix cluster and node name in driver (#123601)

Author: idegtiarenko

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/planner/LocalExecutionPlanner.java

@@ -198,8 +198,8 @@ public LocalExecutionPlan plan(String taskDescription, FoldContext foldCtx, Phys
             new DriverFactory(
                 new DriverSupplier(
                     taskDescription,
-                    Node.NODE_NAME_SETTING.get(settings),
                     ClusterName.CLUSTER_NAME_SETTING.get(settings).value(),
+                    Node.NODE_NAME_SETTING.get(settings),
                     context.bigArrays,
                     context.blockFactory,
                     physicalOperation,

x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/planner/LocalExecutionPlannerTests.java

@@ -17,6 +17,7 @@
 import org.apache.lucene.search.IndexSearcher;
 import org.apache.lucene.store.Directory;
 import org.apache.lucene.tests.index.RandomIndexWriter;
+import org.elasticsearch.cluster.ClusterName;
 import org.elasticsearch.common.settings.Settings;
 import org.elasticsearch.common.util.BigArrays;
 import org.elasticsearch.compute.lucene.LuceneSourceOperator;
@@ -29,6 +30,7 @@
 import org.elasticsearch.index.IndexMode;
 import org.elasticsearch.index.cache.query.TrivialQueryCachingPolicy;
 import org.elasticsearch.index.mapper.MapperServiceTestCase;
+import org.elasticsearch.node.Node;
 import org.elasticsearch.search.internal.AliasFilter;
 import org.elasticsearch.search.internal.ContextIndexSearcher;
 import org.elasticsearch.xpack.esql.core.expression.FieldAttribute;
@@ -159,6 +161,29 @@ public void testLuceneTopNSourceOperatorDistanceSort() throws IOException {
         assertThat(factory.limit(), equalTo(10));
     }
 
+    public void testDriverClusterAndNodeName() throws IOException {
+        int estimatedRowSize = randomEstimatedRowSize(estimatedRowSizeIsHuge);
+        LocalExecutionPlanner.LocalExecutionPlan plan = planner().plan(
+            "test",
+            FoldContext.small(),
+            new EsQueryExec(
+                Source.EMPTY,
+                index().name(),
+                IndexMode.STANDARD,
+                index().indexNameWithModes(),
+                List.of(),
+                null,
+                null,
+                null,
+                estimatedRowSize
+            )
+        );
+        assertThat(plan.driverFactories.size(), lessThanOrEqualTo(pragmas.taskConcurrency()));
+        LocalExecutionPlanner.DriverSupplier supplier = plan.driverFactories.get(0).driverSupplier();
+        assertThat(supplier.clusterName(), equalTo("dev-cluster"));
+        assertThat(supplier.nodeName(), equalTo("node-1"));
+    }
+
     private int randomEstimatedRowSize(boolean huge) {
         int hugeBoundary = SourceOperator.MIN_TARGET_PAGE_SIZE * 10;
         return huge ? between(hugeBoundary, Integer.MAX_VALUE) : between(1, hugeBoundary);
@@ -179,7 +204,10 @@ private LocalExecutionPlanner planner() throws IOException {
             null,
             BigArrays.NON_RECYCLING_INSTANCE,
             TestBlockFactory.getNonBreakingInstance(),
-            Settings.EMPTY,
+            Settings.builder()
+                .put(ClusterName.CLUSTER_NAME_SETTING.getKey(), "dev-cluster")
+                .put(Node.NODE_NAME_SETTING.getKey(), "node-1")
+                .build(),
             config(),
             null,
             null,