From 4c09e1b31dcaff2bc0a73b83ba3bdaafa63d4bd5 Mon Sep 17 00:00:00 2001 From: Tor Brede Vekterli Date: Thu, 14 Oct 2021 14:52:50 +0200 Subject: Add feature flag for enhanced distributor maintenance scheduling --- .../java/com/yahoo/vespa/config/server/deploy/ModelContextImpl.java | 3 +++ 1 file changed, 3 insertions(+) (limited to 'configserver') diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/deploy/ModelContextImpl.java b/configserver/src/main/java/com/yahoo/vespa/config/server/deploy/ModelContextImpl.java index b25bbf1a5bb..c994a25602a 100644 --- a/configserver/src/main/java/com/yahoo/vespa/config/server/deploy/ModelContextImpl.java +++ b/configserver/src/main/java/com/yahoo/vespa/config/server/deploy/ModelContextImpl.java @@ -194,6 +194,7 @@ public class ModelContextImpl implements ModelContext { private final int distributorMergeBusyWait; private final int docstoreCompressionLevel; private final double diskBloatFactor; + private final boolean distributorEnhancedMaintenanceScheduling; public FeatureFlags(FlagSource source, ApplicationId appId) { this.defaultTermwiseLimit = flagValue(source, appId, Flags.DEFAULT_TERM_WISE_LIMIT); @@ -226,6 +227,7 @@ public class ModelContextImpl implements ModelContext { this.distributorMergeBusyWait = flagValue(source, appId, Flags.DISTRIBUTOR_MERGE_BUSY_WAIT); this.docstoreCompressionLevel = flagValue(source, appId, Flags.DOCSTORE_COMPRESSION_LEVEL); this.diskBloatFactor = flagValue(source, appId, Flags.DISK_BLOAT_FACTOR); + this.distributorEnhancedMaintenanceScheduling = flagValue(source, appId, Flags.DISTRIBUTOR_ENHANCED_MAINTENANCE_SCHEDULING); } @Override public double defaultTermwiseLimit() { return defaultTermwiseLimit; } @@ -260,6 +262,7 @@ public class ModelContextImpl implements ModelContext { @Override public int distributorMergeBusyWait() { return distributorMergeBusyWait; } @Override public double diskBloatFactor() { return diskBloatFactor; } @Override public int docstoreCompressionLevel() { return docstoreCompressionLevel; } + @Override public boolean distributorEnhancedMaintenanceScheduling() { return distributorEnhancedMaintenanceScheduling; } private static V flagValue(FlagSource source, ApplicationId appId, UnboundFlag flag) { return flag.bindTo(source) -- cgit v1.2.3