diff options
author | Arne H Juul <arnej27959@users.noreply.github.com> | 2021-10-21 15:44:29 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-10-21 15:44:29 +0200 |
commit | 44030f533278a9ffa071779c057511be12ec3c8d (patch) | |
tree | 81ac49b27510deabfac10d74b285982e8b464aee /config-model | |
parent | 00cd069173c9c4d7a8da17eb093f013374a0616e (diff) | |
parent | b764ec9a3e44d28a75fc0f748039a8326ff0617c (diff) |
Merge pull request #19654 from vespa-engine/arnej/allow-discarding-issues
add forward_issues config option
Diffstat (limited to 'config-model')
-rw-r--r-- | config-model/src/main/java/com/yahoo/vespa/model/content/ContentSearchCluster.java | 13 |
1 files changed, 8 insertions, 5 deletions
diff --git a/config-model/src/main/java/com/yahoo/vespa/model/content/ContentSearchCluster.java b/config-model/src/main/java/com/yahoo/vespa/model/content/ContentSearchCluster.java index 1200b7467b4..ff9db4a10bf 100644 --- a/config-model/src/main/java/com/yahoo/vespa/model/content/ContentSearchCluster.java +++ b/config-model/src/main/java/com/yahoo/vespa/model/content/ContentSearchCluster.java @@ -68,6 +68,7 @@ public class ContentSearchCluster extends AbstractConfigProducer<SearchCluster> private final double defaultFeedConcurrency; private final double defaultDiskBloatFactor; private final int defaultDocStoreCompressionLevel; + private final boolean forwardIssuesToQrs; /** Whether the nodes of this cluster also hosts a container cluster in a hosted system */ private final boolean combined; @@ -210,11 +211,12 @@ public class ContentSearchCluster extends AbstractConfigProducer<SearchCluster> this.syncTransactionLog = syncTransactionLog; this.combined = combined; - feedSequencerType = convertFeedSequencerType(featureFlags.feedSequencerType()); - feedTaskLimit = featureFlags.feedTaskLimit(); - defaultFeedConcurrency = featureFlags.feedConcurrency(); - defaultDocStoreCompressionLevel = featureFlags.docstoreCompressionLevel(); - defaultDiskBloatFactor = featureFlags.diskBloatFactor(); + this.feedSequencerType = convertFeedSequencerType(featureFlags.feedSequencerType()); + this.feedTaskLimit = featureFlags.feedTaskLimit(); + this.defaultFeedConcurrency = featureFlags.feedConcurrency(); + this.defaultDiskBloatFactor = featureFlags.diskBloatFactor(); + this.defaultDocStoreCompressionLevel = featureFlags.docstoreCompressionLevel(); + this.forwardIssuesToQrs = featureFlags.forwardIssuesAsErrors(); } public void setVisibilityDelay(double delay) { @@ -411,6 +413,7 @@ public class ContentSearchCluster extends AbstractConfigProducer<SearchCluster> builder.flush.memory.each.diskbloatfactor(defaultDiskBloatFactor); builder.summary.log.chunk.compression.level(defaultDocStoreCompressionLevel); builder.summary.log.compact.compression.level(defaultDocStoreCompressionLevel); + builder.forward_issues(forwardIssuesToQrs); int numDocumentDbs = builder.documentdb.size(); builder.initialize(new ProtonConfig.Initialize.Builder().threads(numDocumentDbs + 1)); |