summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorHarald Musum <musum@verizonmedia.com>2020-10-04 15:56:53 +0200
committerHarald Musum <musum@verizonmedia.com>2020-10-04 15:56:53 +0200
commit88bd738d7fd294d86b911191754cb4971b1bb9b4 (patch)
tree0494a454026c693ae3d92195830163c4fd9d04f3
parent15ec3b7e3bd97980b65796e62b563cf262768821 (diff)
Remove unused throttle policy override
Seems to have not been used in a very long time, should be implemented with a feature flag if needed
-rw-r--r--node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/NodeRepositoryMaintenance.java18
1 files changed, 1 insertions, 17 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/NodeRepositoryMaintenance.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/NodeRepositoryMaintenance.java
index 0f351ff338d..95143a07576 100644
--- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/NodeRepositoryMaintenance.java
+++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/NodeRepositoryMaintenance.java
@@ -20,9 +20,7 @@ import com.yahoo.vespa.service.monitor.ServiceMonitor;
import java.time.Clock;
import java.time.Duration;
-import java.util.Arrays;
import java.util.Optional;
-import java.util.logging.Logger;
/**
* A component which sets up all the node repo maintenance jobs.
@@ -31,9 +29,6 @@ import java.util.logging.Logger;
*/
public class NodeRepositoryMaintenance extends AbstractComponent {
- private static final Logger log = Logger.getLogger(NodeRepositoryMaintenance.class.getName());
- private static final String envPrefix = "vespa_node_repository__";
-
private final NodeFailer nodeFailer;
private final PeriodicApplicationMaintainer periodicApplicationMaintainer;
private final OperatorChangeApplicationMaintainer operatorChangeApplicationMaintainer;
@@ -74,7 +69,7 @@ public class NodeRepositoryMaintenance extends AbstractComponent {
DefaultTimes defaults = new DefaultTimes(zone, Flags.CONFIGSERVER_DISTRIBUTE_APPLICATION_PACKAGE.bindTo(flagSource).value());
nodeFailer = new NodeFailer(deployer, hostLivenessTracker, serviceMonitor, nodeRepository, defaults.failGrace,
- defaults.nodeFailerInterval, clock, orchestrator, throttlePolicyFromEnv().orElse(defaults.throttlePolicy), metric);
+ defaults.nodeFailerInterval, clock, orchestrator, defaults.throttlePolicy, metric);
periodicApplicationMaintainer = new PeriodicApplicationMaintainer(deployer, metric, nodeRepository,
defaults.redeployMaintainerInterval, defaults.periodicRedeployInterval, flagSource);
operatorChangeApplicationMaintainer = new OperatorChangeApplicationMaintainer(deployer, metric, nodeRepository, defaults.operatorChangeRedeployInterval);
@@ -126,17 +121,6 @@ public class NodeRepositoryMaintenance extends AbstractComponent {
scalingSuggestionsMaintainer.close();
}
- private static Optional<NodeFailer.ThrottlePolicy> throttlePolicyFromEnv() {
- String policyName = System.getenv(envPrefix + "throttle_policy");
- try {
- return Optional.ofNullable(policyName).map(NodeFailer.ThrottlePolicy::valueOf);
- } catch (IllegalArgumentException e) {
- log.info(String.format("Ignoring invalid throttle policy name: '%s'. Must be one of %s", policyName,
- Arrays.toString(NodeFailer.ThrottlePolicy.values())));
- return Optional.empty();
- }
- }
-
private static class DefaultTimes {
// TODO: Rename, kept now for compatibility reasons, want to change this and corresponding env variable