32
32
import org .elasticsearch .action .support .ActionFilters ;
33
33
import org .elasticsearch .action .support .HandledTransportAction ;
34
34
import org .elasticsearch .client .internal .Client ;
35
- import org .elasticsearch .common . inject .Inject ;
35
+ import org .elasticsearch .injection . guice .Inject ;
36
36
import org .elasticsearch .common .settings .ClusterSettings ;
37
37
import org .elasticsearch .common .settings .Settings ;
38
38
import org .elasticsearch .common .util .concurrent .EsExecutors ;
@@ -114,7 +114,7 @@ private AsyncAction(ActionListener<NodePrometheusMetricsResponse> listener) {
114
114
this .listener = listener ;
115
115
116
116
// Note: when using ClusterHealthRequest in Java, it pulls data at the shards level, according to ES source
117
- this .healthRequest = new ClusterHealthRequest ().local (true );
117
+ this .healthRequest = new ClusterHealthRequest (ClusterStateRequest . DEFAULT_WAIT_FOR_NODE_TIMEOUT ).local (true );
118
118
119
119
this .nodesStatsRequest = new NodesStatsRequest ("_local" ).clear ().all ();
120
120
@@ -124,7 +124,7 @@ private AsyncAction(ActionListener<NodePrometheusMetricsResponse> listener) {
124
124
125
125
// Cluster settings are get via ClusterStateRequest (see elasticsearch RestClusterGetSettingsAction for details)
126
126
// We prefer to send it to master node (hence local=false; it should be set by default, but we want to be sure).
127
- this .clusterStateRequest = isPrometheusClusterSettings ? new ClusterStateRequest ().clear ().metadata (
127
+ this .clusterStateRequest = isPrometheusClusterSettings ? new ClusterStateRequest (ClusterStateRequest . DEFAULT_WAIT_FOR_NODE_TIMEOUT ).clear ().metadata (
128
128
true ).local (false ) : null ;
129
129
}
130
130
0 commit comments