39
39
import org .opensearch .core .action .ActionListener ;
40
40
import org .opensearch .core .common .io .stream .Writeable ;
41
41
import org .opensearch .tasks .Task ;
42
- import org .opensearch .threadpool .ThreadPool ;
43
42
import org .opensearch .transport .TransportService ;
44
- import org .opensearch .wlm .QueryGroupTask ;
45
43
46
44
/**
47
45
* Perform the search scroll
@@ -53,32 +51,24 @@ public class TransportSearchScrollAction extends HandledTransportAction<SearchSc
53
51
private final ClusterService clusterService ;
54
52
private final SearchTransportService searchTransportService ;
55
53
private final SearchPhaseController searchPhaseController ;
56
- private final ThreadPool threadPool ;
57
54
58
55
@ Inject
59
56
public TransportSearchScrollAction (
60
57
TransportService transportService ,
61
58
ClusterService clusterService ,
62
59
ActionFilters actionFilters ,
63
60
SearchTransportService searchTransportService ,
64
- SearchPhaseController searchPhaseController ,
65
- ThreadPool threadPool
61
+ SearchPhaseController searchPhaseController
66
62
) {
67
63
super (SearchScrollAction .NAME , transportService , actionFilters , (Writeable .Reader <SearchScrollRequest >) SearchScrollRequest ::new );
68
64
this .clusterService = clusterService ;
69
65
this .searchTransportService = searchTransportService ;
70
66
this .searchPhaseController = searchPhaseController ;
71
- this .threadPool = threadPool ;
72
67
}
73
68
74
69
@ Override
75
70
protected void doExecute (Task task , SearchScrollRequest request , ActionListener <SearchResponse > listener ) {
76
71
try {
77
-
78
- if (task instanceof QueryGroupTask ) {
79
- ((QueryGroupTask ) task ).setQueryGroupId (threadPool .getThreadContext ());
80
- }
81
-
82
72
ParsedScrollId scrollId = TransportSearchHelper .parseScrollId (request .scrollId ());
83
73
Runnable action ;
84
74
switch (scrollId .getType ()) {
0 commit comments