diff options
author | Jon Bratseth <bratseth@oath.com> | 2020-09-23 15:23:38 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-09-23 15:23:38 +0200 |
commit | 181b198578ce66e2759a450a9ee6adc8ca4f9134 (patch) | |
tree | b39e8ddda585e7092fe39fa01698fd5ea7968fa7 | |
parent | 54a1714cc5b350a1b13d3b7c049d08e962119302 (diff) | |
parent | a1a76e86064fda3c93b40cfb3d79e8f02c9a88be (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.java | 3 |
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)); } } |