3939import org .opensearch .core .action .ActionListener ;
4040import org .opensearch .core .common .io .stream .Writeable ;
4141import org .opensearch .tasks .Task ;
42- import org .opensearch .threadpool .ThreadPool ;
4342import org .opensearch .transport .TransportService ;
44- import org .opensearch .wlm .QueryGroupTask ;
4543
4644/**
4745 * Perform the search scroll
@@ -53,32 +51,24 @@ public class TransportSearchScrollAction extends HandledTransportAction<SearchSc
5351 private final ClusterService clusterService ;
5452 private final SearchTransportService searchTransportService ;
5553 private final SearchPhaseController searchPhaseController ;
56- private final ThreadPool threadPool ;
5754
5855 @ Inject
5956 public TransportSearchScrollAction (
6057 TransportService transportService ,
6158 ClusterService clusterService ,
6259 ActionFilters actionFilters ,
6360 SearchTransportService searchTransportService ,
64- SearchPhaseController searchPhaseController ,
65- ThreadPool threadPool
61+ SearchPhaseController searchPhaseController
6662 ) {
6763 super (SearchScrollAction .NAME , transportService , actionFilters , (Writeable .Reader <SearchScrollRequest >) SearchScrollRequest ::new );
6864 this .clusterService = clusterService ;
6965 this .searchTransportService = searchTransportService ;
7066 this .searchPhaseController = searchPhaseController ;
71- this .threadPool = threadPool ;
7267 }
7368
7469 @ Override
7570 protected void doExecute (Task task , SearchScrollRequest request , ActionListener <SearchResponse > listener ) {
7671 try {
77-
78- if (task instanceof QueryGroupTask ) {
79- ((QueryGroupTask ) task ).setQueryGroupId (threadPool .getThreadContext ());
80- }
81-
8272 ParsedScrollId scrollId = TransportSearchHelper .parseScrollId (request .scrollId ());
8373 Runnable action ;
8474 switch (scrollId .getType ()) {
0 commit comments