Skip to content

Commit 459f230

Browse files
committed
fix usages
1 parent c4a00c3 commit 459f230

File tree

5 files changed

+13
-9
lines changed

5 files changed

+13
-9
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -643,8 +643,8 @@ void executeSubPlan(
643643
bigArrays,
644644
blockFactory,
645645
randomNodeSettings(),
646-
configuration,
647646
TestNodeInfoSupplier.INSTANCE,
647+
configuration,
648648
exchangeSource::createExchangeSource,
649649
() -> exchangeSink.createExchangeSink(() -> {}),
650650
Mockito.mock(EnrichLookupService.class),

x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/action/EsqlQueryResponseProfileTests.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -7,8 +7,6 @@
77

88
package org.elasticsearch.xpack.esql.action;
99

10-
import com.carrotsearch.randomizedtesting.generators.RandomStrings;
11-
1210
import org.elasticsearch.common.io.stream.NamedWriteableRegistry;
1311
import org.elasticsearch.common.io.stream.Writeable;
1412
import org.elasticsearch.compute.data.BlockWritables;
@@ -51,7 +49,9 @@ private List<DriverProfile> randomDriverProfiles() {
5149

5250
private DriverProfile randomDriverProfile() {
5351
return new DriverProfile(
54-
RandomStrings.randomAsciiLettersOfLength(random(), 5),
52+
randomIdentifier(),
53+
randomIdentifier(),
54+
randomIdentifier(),
5555
randomNonNegativeLong(),
5656
randomNonNegativeLong(),
5757
randomNonNegativeLong(),

x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/action/EsqlQueryResponseTests.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -724,6 +724,8 @@ public void testProfileXContent() {
724724
List.of(
725725
new DriverProfile(
726726
"test",
727+
"elasticsearch",
728+
"node-1",
727729
1723489812649L,
728730
1723489819929L,
729731
20021,
@@ -759,6 +761,8 @@ public void testProfileXContent() {
759761
"drivers" : [
760762
{
761763
"task_description" : "test",
764+
"cluster_name" : "elasticsearch",
765+
"node_name" : "node-1",
762766
"start_millis" : 1723489812649,
763767
"stop_millis" : 1723489819929,
764768
"took_nanos" : 20021,

x-pack/plugin/esql/src/test/java/org/elasticsearch/xpack/esql/optimizer/PhysicalPlanOptimizerTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7596,8 +7596,8 @@ private LocalExecutionPlanner.LocalExecutionPlan physicalOperationsFromPhysicalP
75967596
BigArrays.NON_RECYCLING_INSTANCE,
75977597
TestBlockFactory.getNonBreakingInstance(),
75987598
Settings.EMPTY,
7599-
config,
76007599
TestNodeInfoSupplier.INSTANCE,
7600+
config,
76017601
new ExchangeSourceHandler(10, null)::createExchangeSource,
76027602
() -> exchangeSinkHandler.createExchangeSink(() -> {}),
76037603
null,

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

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -7,8 +7,6 @@
77

88
package org.elasticsearch.xpack.esql.plugin;
99

10-
import com.carrotsearch.randomizedtesting.generators.RandomStrings;
11-
1210
import org.elasticsearch.action.ActionListener;
1311
import org.elasticsearch.action.ActionRunnable;
1412
import org.elasticsearch.action.support.PlainActionFuture;
@@ -64,7 +62,9 @@ private List<DriverProfile> randomProfiles() {
6462
for (int i = 0; i < numProfiles; i++) {
6563
profiles.add(
6664
new DriverProfile(
67-
RandomStrings.randomAsciiLettersOfLength(random(), 5),
65+
randomIdentifier(),
66+
randomIdentifier(),
67+
randomIdentifier(),
6868
randomNonNegativeLong(),
6969
randomNonNegativeLong(),
7070
randomNonNegativeLong(),
@@ -121,7 +121,7 @@ public void testCollectComputeResults() {
121121
assertThat(onFailure.get(), equalTo(0));
122122
}
123123

124-
public void testCancelOnFailure() throws Exception {
124+
public void testCancelOnFailure() {
125125
Queue<Exception> rootCauseExceptions = ConcurrentCollections.newQueue();
126126
IntStream.range(0, between(1, 100))
127127
.forEach(

0 commit comments

Comments
 (0)