summaryrefslogtreecommitdiffstats
path: root/config-model/src/test/java
diff options
context:
space:
mode:
authorTor Brede Vekterli <vekterli@vespa.ai>2024-04-12 11:54:16 +0200
committerTor Brede Vekterli <vekterli@vespa.ai>2024-04-12 11:57:22 +0200
commitb805ba686f175b9a3fb6182e36348c093fb78c72 (patch)
treeb11e3aa4ebc2f7b271318991cd4096f4f7b483f0 /config-model/src/test/java
parent1d8cd8366c4d918459f2df1c873eb2206f1c1e11 (diff)
Add feature flag for controlling max feed operation batch size
Currently defaults to 1, which disables batching.
Diffstat (limited to 'config-model/src/test/java')
-rw-r--r--config-model/src/test/java/com/yahoo/vespa/model/content/StorageClusterTest.java17
1 files changed, 17 insertions, 0 deletions
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 0dd03d258b9..f56e642edd7 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
@@ -336,6 +336,23 @@ public class StorageClusterTest {
assertEquals(3.0, config.async_operation_throttler().resize_rate(), 0.0001);
}
+ private void verifyMaxFeedOpBatchSize(int expected, Integer flagValue) {
+ var props = new TestProperties();
+ if (flagValue != null) {
+ props.setPersistenceThreadMaxFeedOpBatchSize(flagValue);
+ }
+ var config = filestorConfigFromProducer(simpleCluster(props));
+ assertEquals(expected, config.max_feed_op_batch_size());
+ }
+
+ @Test
+ void persistence_max_feed_op_batch_size_is_controlled_by_feature_flag() {
+ // TODO update default once rolled out and tested
+ verifyMaxFeedOpBatchSize(1, null);
+ verifyMaxFeedOpBatchSize(1, 1);
+ verifyMaxFeedOpBatchSize(1234, 1234);
+ }
+
@Test
void testCapacity() {
String xml = joinLines(