Skip to content

Commit

Permalink
remove non releated changes
Browse files Browse the repository at this point in the history
Signed-off-by: Kaushal Kumar <[email protected]>
  • Loading branch information
kaushalmahi12 committed May 16, 2024
1 parent 675a105 commit c8f262b
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 7 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -180,7 +180,7 @@ private AbstractSearchAsyncAction<SearchPhaseResult> createAction(
new GroupShardsIterator<>(Arrays.asList(shards)),
timeProvider,
ClusterState.EMPTY_STATE,
new SearchTask(123, null, null, null, null, null),
null,
results,
request.getMaxConcurrentShardRequests(),
SearchResponse.Clusters.EMPTY,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -160,7 +160,7 @@ public void sendCanMatch(
shardsIter,
timeProvider,
ClusterState.EMPTY_STATE,
new SearchTask(1, null, null, null, null, null),
null,
(iter) -> new SearchPhase("test") {
@Override
public void run() throws IOException {
Expand Down Expand Up @@ -258,7 +258,7 @@ public void sendCanMatch(
shardsIter,
timeProvider,
ClusterState.EMPTY_STATE,
new SearchTask(1, null, null, null, null, null),
null,
(iter) -> new SearchPhase("test") {
@Override
public void run() throws IOException {
Expand Down Expand Up @@ -346,7 +346,7 @@ public void sendCanMatch(
shardsIter,
timeProvider,
ClusterState.EMPTY_STATE,
new SearchTask(1, null, null, null, null, null),
null,
(iter) -> {
return new WrappingSearchAsyncActionPhase(
new AbstractSearchAsyncAction<SearchPhaseResult>("test", logger, transportService, (cluster, node) -> {
Expand Down Expand Up @@ -478,7 +478,7 @@ public void sendCanMatch(
shardsIter,
timeProvider,
ClusterState.EMPTY_STATE,
new SearchTask(1, null, null, null, null, null),
null,
(iter) -> new SearchPhase("test") {
@Override
public void run() {
Expand Down Expand Up @@ -585,7 +585,7 @@ public void sendCanMatch(
shardsIter,
timeProvider,
ClusterState.EMPTY_STATE,
new SearchTask(1, null, null, null, null, null),
null,
(iter) -> new SearchPhase("test") {
@Override
public void run() {
Expand Down Expand Up @@ -690,7 +690,7 @@ public void sendCanMatch(
shardsIter,
timeProvider,
ClusterState.EMPTY_STATE,
new SearchTask(1, null, null, null, null, null),
null,
(iter) -> {
AbstractSearchAsyncAction<? extends SearchPhaseResult> action = new SearchDfsQueryAsyncAction(
logger,
Expand Down

0 comments on commit c8f262b

Please sign in to comment.