2828import org .elasticsearch .action .support .HandledTransportAction ;
2929import org .elasticsearch .action .support .IndicesOptions ;
3030import org .elasticsearch .action .support .SubscribableListener ;
31- import org .elasticsearch .client .internal .Client ;
3231import org .elasticsearch .cluster .ClusterState ;
3332import org .elasticsearch .cluster .service .ClusterService ;
3433import org .elasticsearch .common .bytes .BytesReference ;
@@ -89,7 +88,6 @@ public class TransportOpenPointInTimeAction extends HandledTransportAction<OpenP
8988 private final SearchService searchService ;
9089 private final ClusterService clusterService ;
9190 private final SearchResponseMetrics searchResponseMetrics ;
92- private final Client client ;
9391 private final CrossProjectModeDecider crossProjectModeDecider ;
9492 private final TimeValue forceConnectTimeoutSecs ;
9593
@@ -102,8 +100,7 @@ public TransportOpenPointInTimeAction(
102100 SearchTransportService searchTransportService ,
103101 NamedWriteableRegistry namedWriteableRegistry ,
104102 ClusterService clusterService ,
105- SearchResponseMetrics searchResponseMetrics ,
106- Client client
103+ SearchResponseMetrics searchResponseMetrics
107104 ) {
108105 super (TYPE .name (), transportService , actionFilters , OpenPointInTimeRequest ::new , EsExecutors .DIRECT_EXECUTOR_SERVICE );
109106 this .transportService = transportService ;
@@ -113,7 +110,6 @@ public TransportOpenPointInTimeAction(
113110 this .namedWriteableRegistry = namedWriteableRegistry ;
114111 this .clusterService = clusterService ;
115112 this .searchResponseMetrics = searchResponseMetrics ;
116- this .client = client ;
117113 this .crossProjectModeDecider = new CrossProjectModeDecider (clusterService .getSettings ());
118114 this .forceConnectTimeoutSecs = clusterService .getSettings ()
119115 .getAsTime ("search.ccs.force_connect_timeout" , TimeValue .timeValueSeconds (3L ));
0 commit comments