Skip to content

Commit e10b7b1

Browse files
committed
fix usages
1 parent 0724840 commit e10b7b1

File tree

2 files changed

+0
-6
lines changed

2 files changed

+0
-6
lines changed

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

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -199,7 +199,6 @@ protected void sendRequest(
199199
);
200200
}
201201
}.startComputeOnDataNodes(
202-
clusterAlias,
203202
concreteIndices,
204203
originalIndices,
205204
PlannerUtils.canMatchFilter(dataNodePlan),

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

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,6 @@
2828
import org.elasticsearch.index.shard.ShardId;
2929
import org.elasticsearch.search.internal.AliasFilter;
3030
import org.elasticsearch.tasks.CancellableTask;
31-
import org.elasticsearch.tasks.Task;
3231
import org.elasticsearch.tasks.TaskId;
3332
import org.elasticsearch.test.transport.MockTransportService;
3433
import org.elasticsearch.threadpool.FixedExecutorBuilder;
@@ -474,8 +473,6 @@ PlainActionFuture<ComputeResponse> sendRequests(
474473
) {
475474
@Override
476475
void searchShards(
477-
Task parentTask,
478-
String clusterAlias,
479476
QueryBuilder filter,
480477
Set<String> concreteIndices,
481478
OriginalIndices originalIndices,
@@ -486,7 +483,6 @@ void searchShards(
486483
shards.size(),
487484
0
488485
);
489-
assertSame(parentTask, task);
490486
runWithDelay(() -> listener.onResponse(targetShards));
491487
}
492488

@@ -501,7 +497,6 @@ protected void sendRequest(
501497
}
502498
};
503499
requestSender.startComputeOnDataNodes(
504-
"",
505500
Set.of(randomAlphaOfLength(10)),
506501
new OriginalIndices(new String[0], SearchRequest.DEFAULT_INDICES_OPTIONS),
507502
null,

0 commit comments

Comments
 (0)