summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorJon Marius Venstad <jonmv@users.noreply.github.com>2018-09-24 10:04:36 +0200
committerGitHub <noreply@github.com>2018-09-24 10:04:36 +0200
commitc64c7a0bb849ef6ac4aff89aea720071c3e01b39 (patch)
tree7e27fa663227ed6a24f52cd06e680ddb8b303786
parent54938676a144a8a137ad6c210257b4724f05eb98 (diff)
parent1fdd0a4af31eb6c0614f8de3988e7c3475b68836 (diff)
Merge pull request #7058 from vespa-engine/revert-7055-mpolden/revert-to-single-threaded
Revert "Revert to single-threaded update of metrics"
-rw-r--r--controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/DeploymentMetricsMaintainer.java2
1 files changed, 1 insertions, 1 deletions
diff --git a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/DeploymentMetricsMaintainer.java b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/DeploymentMetricsMaintainer.java
index 03123d281a5..6ea9d548367 100644
--- a/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/DeploymentMetricsMaintainer.java
+++ b/controller-server/src/main/java/com/yahoo/vespa/hosted/controller/maintenance/DeploymentMetricsMaintainer.java
@@ -51,7 +51,7 @@ public class DeploymentMetricsMaintainer extends Maintainer {
// Run parallel stream inside a custom ForkJoinPool so that we can control the number of threads used
ForkJoinPool pool = new ForkJoinPool(applicationsToUpdateInParallel);
pool.submit(() -> {
- applicationList.stream().forEach(application -> {
+ applicationList.parallelStream().forEach(application -> {
try {
applications.lockIfPresent(application.id(), locked ->
applications.store(locked.with(controller().metricsService().getApplicationMetrics(application.id()))));