@@ -143,13 +143,6 @@ public class TransportSearchAction extends HandledTransportAction<SearchRequest,
143
143
Property .NodeScope
144
144
);
145
145
146
- public static final Setting <Boolean > SEARCH_QUERY_METRICS_ENABLED_SETTING = Setting .boolSetting (
147
- "search.query.metrics.enabled" ,
148
- false ,
149
- Setting .Property .NodeScope ,
150
- Setting .Property .Dynamic
151
- );
152
-
153
146
// cluster level setting for timeout based search cancellation. If search request level parameter is present then that will take
154
147
// precedence over the cluster setting value
155
148
public static final String SEARCH_CANCEL_AFTER_TIME_INTERVAL_SETTING_KEY = "search.cancel_after_time_interval" ;
@@ -182,11 +175,8 @@ public class TransportSearchAction extends HandledTransportAction<SearchRequest,
182
175
private final SearchRequestOperationsCompositeListenerFactory searchRequestOperationsCompositeListenerFactory ;
183
176
private final Tracer tracer ;
184
177
185
- private volatile boolean searchQueryMetricsEnabled ;
186
-
187
178
private final MetricsRegistry metricsRegistry ;
188
179
189
- private SearchQueryCategorizer searchQueryCategorizer ;
190
180
private TaskResourceTrackingService taskResourceTrackingService ;
191
181
192
182
@ Inject
@@ -222,21 +212,11 @@ public TransportSearchAction(
222
212
this .namedWriteableRegistry = namedWriteableRegistry ;
223
213
this .searchPipelineService = searchPipelineService ;
224
214
this .metricsRegistry = metricsRegistry ;
225
- this .searchQueryMetricsEnabled = clusterService .getClusterSettings ().get (SEARCH_QUERY_METRICS_ENABLED_SETTING );
226
215
this .searchRequestOperationsCompositeListenerFactory = searchRequestOperationsCompositeListenerFactory ;
227
- clusterService .getClusterSettings ()
228
- .addSettingsUpdateConsumer (SEARCH_QUERY_METRICS_ENABLED_SETTING , this ::setSearchQueryMetricsEnabled );
229
216
this .tracer = tracer ;
230
217
this .taskResourceTrackingService = taskResourceTrackingService ;
231
218
}
232
219
233
- private void setSearchQueryMetricsEnabled (boolean searchQueryMetricsEnabled ) {
234
- this .searchQueryMetricsEnabled = searchQueryMetricsEnabled ;
235
- if ((this .searchQueryMetricsEnabled == true ) && this .searchQueryCategorizer == null ) {
236
- this .searchQueryCategorizer = new SearchQueryCategorizer (metricsRegistry );
237
- }
238
- }
239
-
240
220
private Map <String , AliasFilter > buildPerIndexAliasFilter (
241
221
SearchRequest request ,
242
222
ClusterState clusterState ,
@@ -473,13 +453,6 @@ private void executeRequest(
473
453
}
474
454
475
455
ActionListener <SearchRequest > requestTransformListener = ActionListener .wrap (sr -> {
476
- if (searchQueryMetricsEnabled ) {
477
- try {
478
- searchQueryCategorizer .categorize (sr .source ());
479
- } catch (Exception e ) {
480
- logger .error ("Error while trying to categorize the query." , e );
481
- }
482
- }
483
456
484
457
ActionListener <SearchSourceBuilder > rewriteListener = buildRewriteListener (
485
458
sr ,
0 commit comments