diff options
author | Ola Aunrønning <olaa@verizonmedia.com> | 2019-12-12 16:47:59 +0100 |
---|---|---|
committer | Ola Aunrønning <olaa@verizonmedia.com> | 2019-12-12 16:49:00 +0100 |
commit | 516e924b51075746290eb3d9e802b75dd9e0f41c (patch) | |
tree | 6b629e56b977f09b8d6eb2ddb3db2c2fed5a937c /configserver | |
parent | 5af7654012690bbbf9a88068fa09432591438c85 (diff) |
Use PoolingHttpClientConnectionManager. Increase parallelization
Diffstat (limited to 'configserver')
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/metrics/ClusterMetricsRetriever.java | 18 |
1 files changed, 11 insertions, 7 deletions
diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/metrics/ClusterMetricsRetriever.java b/configserver/src/main/java/com/yahoo/vespa/config/server/metrics/ClusterMetricsRetriever.java index f4e84830646..de08e1b4866 100644 --- a/configserver/src/main/java/com/yahoo/vespa/config/server/metrics/ClusterMetricsRetriever.java +++ b/configserver/src/main/java/com/yahoo/vespa/config/server/metrics/ClusterMetricsRetriever.java @@ -11,6 +11,7 @@ import org.apache.http.client.config.RequestConfig; import org.apache.http.client.methods.CloseableHttpResponse; import org.apache.http.client.methods.HttpGet; import org.apache.http.impl.client.CloseableHttpClient; +import org.apache.http.impl.conn.PoolingHttpClientConnectionManager; import java.io.IOException; import java.io.InputStream; @@ -41,12 +42,15 @@ public class ClusterMetricsRetriever { private static final List<String> WANTED_METRIC_SERVICES = List.of(VESPA_CONTAINER, VESPA_QRSERVER, VESPA_DISTRIBUTOR); - private static final CloseableHttpClient httpClient = VespaHttpClientBuilder.create() - .setDefaultRequestConfig(RequestConfig.custom() - .setConnectTimeout(10 * 1000) - .setSocketTimeout(10 * 1000) - .build()) - .build(); + + private static final CloseableHttpClient httpClient = VespaHttpClientBuilder + .create(PoolingHttpClientConnectionManager::new) + .setDefaultRequestConfig( + RequestConfig.custom() + .setConnectTimeout(10 * 1000) + .setSocketTimeout(10 * 1000) + .build()) + .build(); /** * Call the metrics API on each host and aggregate the metrics @@ -60,7 +64,7 @@ public class ClusterMetricsRetriever { getHostMetrics(host, clusterMetricsMap) ); - ForkJoinPool threadPool = new ForkJoinPool(5); + ForkJoinPool threadPool = new ForkJoinPool(10); threadPool.submit(retrieveMetricsJob); threadPool.shutdown(); |