diff --git a/server/src/main/java/org/opensearch/action/search/TransportSearchAction.java b/server/src/main/java/org/opensearch/action/search/TransportSearchAction.java index 5dd576fa6ce53..1ca477942cdf6 100644 --- a/server/src/main/java/org/opensearch/action/search/TransportSearchAction.java +++ b/server/src/main/java/org/opensearch/action/search/TransportSearchAction.java @@ -340,7 +340,7 @@ public AbstractSearchAsyncAction asyncSearchAction( clusterState, task, new ArraySearchPhaseResults<>(shardsIts.size()), - 1, + searchRequest.getMaxConcurrentShardRequests(), clusters ) { @Override