diff options
author | Tor Brede Vekterli <vekterli@vespa.ai> | 2024-04-12 11:54:16 +0200 |
---|---|---|
committer | Tor Brede Vekterli <vekterli@vespa.ai> | 2024-04-12 11:57:22 +0200 |
commit | b805ba686f175b9a3fb6182e36348c093fb78c72 (patch) | |
tree | b11e3aa4ebc2f7b271318991cd4096f4f7b483f0 /config-model/src/test/java | |
parent | 1d8cd8366c4d918459f2df1c873eb2206f1c1e11 (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.java | 17 |
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( |