diff options
author | Jon Marius Venstad <jonmv@users.noreply.github.com> | 2018-09-24 10:04:36 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-09-24 10:04:36 +0200 |
commit | c64c7a0bb849ef6ac4aff89aea720071c3e01b39 (patch) | |
tree | 7e27fa663227ed6a24f52cd06e680ddb8b303786 | |
parent | 54938676a144a8a137ad6c210257b4724f05eb98 (diff) | |
parent | 1fdd0a4af31eb6c0614f8de3988e7c3475b68836 (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.java | 2 |
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())))); |