summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2022-10-06 15:57:22 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2022-10-06 15:57:22 +0200
commite9d2e1c3c174bb733f4420bd5f0f72311111e092 (patch)
treee403bdef2723e0dc36b895e89ff3577f599f3570
parent3cbbac35a188b578f1360ede59de6175b5d43665 (diff)
GC persistence-throttling-of-merge-feed-ops flag which has long had sane default.
-rw-r--r--config-model-api/src/main/java/com/yahoo/config/model/api/ModelContext.java3
-rw-r--r--config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java7
-rw-r--r--config-model/src/test/java/com/yahoo/vespa/model/content/StorageClusterTest.java4
-rw-r--r--configserver/src/main/java/com/yahoo/vespa/config/server/deploy/ModelContextImpl.java3
-rw-r--r--flags/src/main/java/com/yahoo/vespa/flags/Flags.java10
5 files changed, 2 insertions, 25 deletions
diff --git a/config-model-api/src/main/java/com/yahoo/config/model/api/ModelContext.java b/config-model-api/src/main/java/com/yahoo/config/model/api/ModelContext.java
index 8ea00ef5a79..d2834cd5260 100644
--- a/config-model-api/src/main/java/com/yahoo/config/model/api/ModelContext.java
+++ b/config-model-api/src/main/java/com/yahoo/config/model/api/ModelContext.java
@@ -110,7 +110,6 @@ public interface ModelContext {
@ModelFeatureFlag(owners = {"vekterli"}) default double persistenceThrottlingWsBackoff() { throw new UnsupportedOperationException("TODO specify default value"); }
@ModelFeatureFlag(owners = {"vekterli"}) default int persistenceThrottlingWindowSize() { throw new UnsupportedOperationException("TODO specify default value"); }
@ModelFeatureFlag(owners = {"vekterli"}) default double persistenceThrottlingWsResizeRate() { throw new UnsupportedOperationException("TODO specify default value"); }
- @ModelFeatureFlag(owners = {"vekterli"}) default boolean persistenceThrottlingOfMergeFeedOps() { throw new UnsupportedOperationException("TODO specify default value"); }
@ModelFeatureFlag(owners = {"hmusum"}) default Architecture adminClusterArchitecture() { return Architecture.getDefault(); }
@ModelFeatureFlag(owners = {"tokle"}) default boolean enableProxyProtocolMixedMode() { return true; }
@ModelFeatureFlag(owners = {"arnej"}) default String logFileCompressionAlgorithm(String defVal) { return defVal; }
@@ -132,7 +131,7 @@ public interface ModelContext {
@ModelFeatureFlag(owners = {"baldersheim"}, removeAfter="7.last") default int availableProcessors() { return 1; }
@ModelFeatureFlag(owners = {"vekterli", "geirst"}, removeAfter="7.last") default boolean unorderedMergeChaining() { return true; }
@ModelFeatureFlag(owners = {"vekterli"}, removeAfter="7.last") default String mergeThrottlingPolicy() { return "STATIC"; }
-
+ @ModelFeatureFlag(owners = {"vekterli"}, removeAfter="7.last") default boolean persistenceThrottlingOfMergeFeedOps() { return true; }
}
/** Warning: As elsewhere in this package, do not make backwards incompatible changes that will break old config models! */
diff --git a/config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java b/config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java
index d6de407f1a6..e4234581cc1 100644
--- a/config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java
+++ b/config-model/src/main/java/com/yahoo/config/model/deploy/TestProperties.java
@@ -71,7 +71,6 @@ public class TestProperties implements ModelContext.Properties, ModelContext.Fea
private double persistenceThrottlingWsBackoff = 0.95;
private int persistenceThrottlingWindowSize = -1;
private double persistenceThrottlingWsResizeRate = 3.0;
- private boolean persistenceThrottlingOfMergeFeedOps = true;
private boolean useV8GeoPositions = true;
private List<String> environmentVariables = List.of();
private boolean loadCodeAsHugePages = false;
@@ -130,7 +129,6 @@ public class TestProperties implements ModelContext.Properties, ModelContext.Fea
@Override public double persistenceThrottlingWsBackoff() { return persistenceThrottlingWsBackoff; }
@Override public int persistenceThrottlingWindowSize() { return persistenceThrottlingWindowSize; }
@Override public double persistenceThrottlingWsResizeRate() { return persistenceThrottlingWsResizeRate; }
- @Override public boolean persistenceThrottlingOfMergeFeedOps() { return persistenceThrottlingOfMergeFeedOps; }
@Override public boolean useV8GeoPositions() { return useV8GeoPositions; }
@Override public List<String> environmentVariables() { return environmentVariables; }
@Override public Architecture adminClusterArchitecture() { return adminClusterNodeResourcesArchitecture; }
@@ -345,11 +343,6 @@ public class TestProperties implements ModelContext.Properties, ModelContext.Fea
return this;
}
- public TestProperties setPersistenceThrottlingOfMergeFeedOps(boolean throttleOps) {
- this.persistenceThrottlingOfMergeFeedOps = throttleOps;
- return this;
- }
-
public TestProperties setUseV8GeoPositions(boolean value) {
this.useV8GeoPositions = value;
return this;
diff --git a/config-model/src/test/java/com/yahoo/vespa/model/content/StorageClusterTest.java b/config-model/src/test/java/com/yahoo/vespa/model/content/StorageClusterTest.java
index bde3be562f7..2a9cb2733fb 100644
--- a/config-model/src/test/java/com/yahoo/vespa/model/content/StorageClusterTest.java
+++ b/config-model/src/test/java/com/yahoo/vespa/model/content/StorageClusterTest.java
@@ -332,15 +332,13 @@ public class StorageClusterTest {
.setPersistenceThrottlingWsDecrementFactor(1.5)
.setPersistenceThrottlingWsBackoff(0.8)
.setPersistenceThrottlingWindowSize(42)
- .setPersistenceThrottlingWsResizeRate(2.5)
- .setPersistenceThrottlingOfMergeFeedOps(false)));
+ .setPersistenceThrottlingWsResizeRate(2.5)));
assertEquals(1.5, config.async_operation_throttler().window_size_decrement_factor(), 0.0001);
assertEquals(0.8, config.async_operation_throttler().window_size_backoff(), 0.0001);
// If window size is set, min and max are locked to the same value
assertEquals(42, config.async_operation_throttler().min_window_size());
assertEquals(42, config.async_operation_throttler().max_window_size());
assertEquals(2.5, config.async_operation_throttler().resize_rate(), 0.0001);
- assertFalse(config.async_operation_throttler().throttle_individual_merge_feed_ops());
}
@Test
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 02ea2417c4e..17247b602d2 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
@@ -198,7 +198,6 @@ public class ModelContextImpl implements ModelContext {
private final double persistenceThrottlingWsBackoff;
private final int persistenceThrottlingWindowSize;
private final double persistenceThrottlingWsResizeRate;
- private final boolean persistenceThrottlingOfMergeFeedOps;
private final boolean useQrserverServiceName;
private final boolean avoidRenamingSummaryFeatures;
private final Architecture adminClusterArchitecture;
@@ -248,7 +247,6 @@ public class ModelContextImpl implements ModelContext {
this.persistenceThrottlingWsBackoff = flagValue(source, appId, version, Flags.PERSISTENCE_THROTTLING_WS_BACKOFF);
this.persistenceThrottlingWindowSize = flagValue(source, appId, version, Flags.PERSISTENCE_THROTTLING_WINDOW_SIZE);
this.persistenceThrottlingWsResizeRate = flagValue(source, appId, version, Flags.PERSISTENCE_THROTTLING_WS_RESIZE_RATE);
- this.persistenceThrottlingOfMergeFeedOps = flagValue(source, appId, version, Flags.PERSISTENCE_THROTTLING_OF_MERGE_FEED_OPS);
this.useQrserverServiceName = flagValue(source, appId, version, Flags.USE_QRSERVER_SERVICE_NAME);
this.avoidRenamingSummaryFeatures = flagValue(source, appId, version, Flags.AVOID_RENAMING_SUMMARY_FEATURES);
this.adminClusterArchitecture = Architecture.valueOf(flagValue(source, appId, version, PermanentFlags.ADMIN_CLUSTER_NODE_ARCHITECTURE));
@@ -301,7 +299,6 @@ public class ModelContextImpl implements ModelContext {
@Override public double persistenceThrottlingWsBackoff() { return persistenceThrottlingWsBackoff; }
@Override public int persistenceThrottlingWindowSize() { return persistenceThrottlingWindowSize; }
@Override public double persistenceThrottlingWsResizeRate() { return persistenceThrottlingWsResizeRate; }
- @Override public boolean persistenceThrottlingOfMergeFeedOps() { return persistenceThrottlingOfMergeFeedOps; }
@Override public boolean useQrserverServiceName() { return useQrserverServiceName; }
@Override public boolean avoidRenamingSummaryFeatures() { return avoidRenamingSummaryFeatures; }
@Override public Architecture adminClusterArchitecture() { return adminClusterArchitecture; }
diff --git a/flags/src/main/java/com/yahoo/vespa/flags/Flags.java b/flags/src/main/java/com/yahoo/vespa/flags/Flags.java
index e067278e49c..28f91d1e53f 100644
--- a/flags/src/main/java/com/yahoo/vespa/flags/Flags.java
+++ b/flags/src/main/java/com/yahoo/vespa/flags/Flags.java
@@ -316,16 +316,6 @@ public class Flags {
"Takes effect on redeployment",
ZONE_ID, APPLICATION_ID);
- public static final UnboundBooleanFlag PERSISTENCE_THROTTLING_OF_MERGE_FEED_OPS = defineFeatureFlag(
- "persistence-throttling-of-merge-feed-ops", true,
- List.of("vekterli"), "2022-02-24", "2022-11-01",
- "If true, each put/remove contained within a merge is individually throttled as if it " +
- "were a put/remove from a client. If false, merges are throttled at a persistence thread " +
- "level, i.e. per ApplyBucketDiff message, regardless of how many document operations " +
- "are contained within. Only applies if DYNAMIC policy is used.",
- "Takes effect on redeployment",
- ZONE_ID, APPLICATION_ID);
-
public static final UnboundBooleanFlag USE_QRSERVER_SERVICE_NAME = defineFeatureFlag(
"use-qrserver-service-name", false,
List.of("arnej"), "2022-01-18", "2022-12-31",