summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@oath.com>2020-09-23 15:23:38 +0200
committerGitHub <noreply@github.com>2020-09-23 15:23:38 +0200
commit181b198578ce66e2759a450a9ee6adc8ca4f9134 (patch)
treeb39e8ddda585e7092fe39fa01698fd5ea7968fa7
parent54a1714cc5b350a1b13d3b7c049d08e962119302 (diff)
parenta1a76e86064fda3c93b40cfb3d79e8f02c9a88be (diff)
Merge pull request #14504 from vespa-engine/musum/shorter-wait-for-lock
Wait only a short time for the lock
-rw-r--r--node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/ScalingSuggestionsMaintainer.java3
1 files changed, 2 insertions, 1 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/ScalingSuggestionsMaintainer.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/ScalingSuggestionsMaintainer.java
index b0c52d10f7d..db0e5f03097 100644
--- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/ScalingSuggestionsMaintainer.java
+++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/ScalingSuggestionsMaintainer.java
@@ -62,7 +62,8 @@ public class ScalingSuggestionsMaintainer extends NodeRepositoryMaintainer {
Optional<Cluster> cluster = application.cluster(clusterId);
if (cluster.isEmpty()) return;
Optional<ClusterResources> suggestion = autoscaler.suggest(cluster.get(), clusterNodes);
- try (Mutex lock = nodeRepository().lock(applicationId)) {
+ // Wait only a short time for the lock to avoid interfering with change deployments
+ try (Mutex lock = nodeRepository().lock(applicationId, Duration.ofSeconds(1))) {
applications().get(applicationId).ifPresent(a -> storeSuggestion(suggestion, clusterId, a, lock));
}
}