diff options
author | Geir Storli <geirst@verizonmedia.com> | 2021-11-18 08:56:39 +0000 |
---|---|---|
committer | Geir Storli <geirst@verizonmedia.com> | 2021-11-18 08:56:39 +0000 |
commit | 357eef19d892c33e3e83b4c51cf9985444633848 (patch) | |
tree | bab9c19970fc3c84ad836b473f48dab85da8ab46 /configserver/src | |
parent | 171a0b36e060cdb59c5974a4bc2c723e3b09e0f8 (diff) |
Add feature flag for "feed-master-task-limit".
Diffstat (limited to 'configserver/src')
-rw-r--r-- | configserver/src/main/java/com/yahoo/vespa/config/server/deploy/ModelContextImpl.java | 3 |
1 files changed, 3 insertions, 0 deletions
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 3630215913e..ea823e5befb 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 @@ -168,6 +168,7 @@ public class ModelContextImpl implements ModelContext { private final boolean useThreePhaseUpdates; private final String feedSequencer; private final int feedTaskLimit; + private final int feedMasterTaskLimit; private final String sharedFieldWriterExecutor; private final String responseSequencer; private final int numResponseThreads; @@ -205,6 +206,7 @@ public class ModelContextImpl implements ModelContext { this.useThreePhaseUpdates = flagValue(source, appId, Flags.USE_THREE_PHASE_UPDATES); this.feedSequencer = flagValue(source, appId, Flags.FEED_SEQUENCER_TYPE); this.feedTaskLimit = flagValue(source, appId, Flags.FEED_TASK_LIMIT); + this.feedMasterTaskLimit = flagValue(source, appId, Flags.FEED_MASTER_TASK_LIMIT); this.sharedFieldWriterExecutor = flagValue(source, appId, Flags.SHARED_FIELD_WRITER_EXECUTOR); this.responseSequencer = flagValue(source, appId, Flags.RESPONSE_SEQUENCER_TYPE); this.numResponseThreads = flagValue(source, appId, Flags.RESPONSE_NUM_THREADS); @@ -242,6 +244,7 @@ public class ModelContextImpl implements ModelContext { @Override public boolean useThreePhaseUpdates() { return useThreePhaseUpdates; } @Override public String feedSequencerType() { return feedSequencer; } @Override public int feedTaskLimit() { return feedTaskLimit; } + @Override public int feedMasterTaskLimit() { return feedMasterTaskLimit; } @Override public String sharedFieldWriterExecutor() { return sharedFieldWriterExecutor; } @Override public String responseSequencerType() { return responseSequencer; } @Override public int defaultNumResponseThreads() { return numResponseThreads; } |