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 5dd576fa6ce..1ca477942cd 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 class TransportSearchAction extends HandledTransportAction(shardsIts.size()), - 1, + searchRequest.getMaxConcurrentShardRequests(), clusters ) { @Override