fork in rewriteAndFetchShardRequest

Author: tlrx

server/src/main/java/org/elasticsearch/search/SearchService.java

@@ -1912,7 +1912,11 @@ private void rewriteAndFetchShardRequest(IndexShard shard, ShardSearchRequest re
             request.getRewriteable(),
             indicesService.getDataRewriteContext(request::nowInMillis),
             request.readerId() == null
-                ? listener.delegateFailureAndWrap((l, r) -> shard.ensureShardSearchActive(b -> l.onResponse(request)))
+                ? listener.delegateFailureAndWrap(
+                    (l, r) -> shard.ensureShardSearchActive(
+                        ignored -> threadPool.generic().execute(ActionRunnable.supply(l, () -> request))
+                    )
+                )
                 : listener.safeMap(r -> request)
         );
     }