Skip to content

Commit

Permalink
Addressed naming issue.
Browse files Browse the repository at this point in the history
  • Loading branch information
Hao Xu committed Feb 28, 2025
1 parent 8dcea9c commit 754eb1c
Show file tree
Hide file tree
Showing 4 changed files with 89 additions and 101 deletions.
106 changes: 49 additions & 57 deletions clients/da-vinci-client/src/main/java/com/linkedin/davinci/config/VeniceServerConfig.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@
import static com.linkedin.venice.ConfigKeys.INGESTION_MEMORY_LIMIT_STORE_LIST;
import static com.linkedin.venice.ConfigKeys.INGESTION_MLOCK_ENABLED;
import static com.linkedin.venice.ConfigKeys.INGESTION_USE_DA_VINCI_CLIENT;
import static com.linkedin.venice.ConfigKeys.KAFKA_FETCH_QUOTA_RECORDS_FACTORS_PER_SECOND;
import static com.linkedin.venice.ConfigKeys.KAFKA_FETCH_THROTTLER_FACTORS_PER_SECOND;
import static com.linkedin.venice.ConfigKeys.KAFKA_PRODUCER_METRICS;
import static com.linkedin.venice.ConfigKeys.KEY_VALUE_PROFILING_ENABLED;
import static com.linkedin.venice.ConfigKeys.KME_REGISTRATION_FROM_MESSAGE_HEADER_ENABLED;
Expand Down Expand Up @@ -67,11 +67,6 @@
import static com.linkedin.venice.ConfigKeys.SERVER_COMPUTE_QUEUE_CAPACITY;
import static com.linkedin.venice.ConfigKeys.SERVER_COMPUTE_THREAD_NUM;
import static com.linkedin.venice.ConfigKeys.SERVER_CONSUMER_POOL_ALLOCATION_STRATEGY;
import static com.linkedin.venice.ConfigKeys.SERVER_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_CURRENT_VERSION_AA_WC_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_CURRENT_VERSION_NON_AA_WC_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_CURRENT_VERSION_SEPARATE_RT_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_NON_CURRENT_VERSION_AA_WC_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_NON_CURRENT_VERSION_NON_AA_WC_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_CONSUMER_POOL_SIZE_FOR_CURRENT_VERSION_AA_WC_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_CONSUMER_POOL_SIZE_FOR_CURRENT_VERSION_NON_AA_WC_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_CONSUMER_POOL_SIZE_FOR_CURRENT_VERSION_SEPARATE_RT_LEADER;
Expand All @@ -89,8 +84,6 @@
import static com.linkedin.venice.ConfigKeys.SERVER_DB_READ_ONLY_FOR_BATCH_ONLY_STORE_ENABLED;
import static com.linkedin.venice.ConfigKeys.SERVER_DEBUG_LOGGING_ENABLED;
import static com.linkedin.venice.ConfigKeys.SERVER_DEDICATED_CONSUMER_POOL_FOR_AA_WC_LEADER_ENABLED;
import static com.linkedin.venice.ConfigKeys.SERVER_DEDICATED_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_AA_WC_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_DEDICATED_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_SEP_RT_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_DEDICATED_CONSUMER_POOL_SIZE_FOR_AA_WC_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_DEDICATED_CONSUMER_POOL_SIZE_FOR_SEP_RT_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_DEDICATED_DRAINER_FOR_SORTED_INPUT_ENABLED;
Expand Down Expand Up @@ -172,6 +165,13 @@
import static com.linkedin.venice.ConfigKeys.SERVER_STUCK_CONSUMER_REPAIR_INTERVAL_SECOND;
import static com.linkedin.venice.ConfigKeys.SERVER_STUCK_CONSUMER_REPAIR_THRESHOLD_SECOND;
import static com.linkedin.venice.ConfigKeys.SERVER_SYSTEM_STORE_PROMOTION_TO_LEADER_REPLICA_DELAY_SECONDS;
import static com.linkedin.venice.ConfigKeys.SERVER_THROTTLER_FACTORS_FOR_AA_WC_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_THROTTLER_FACTORS_FOR_CURRENT_VERSION_AA_WC_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_THROTTLER_FACTORS_FOR_CURRENT_VERSION_NON_AA_WC_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_THROTTLER_FACTORS_FOR_CURRENT_VERSION_SEPARATE_RT_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_THROTTLER_FACTORS_FOR_NON_CURRENT_VERSION_AA_WC_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_THROTTLER_FACTORS_FOR_NON_CURRENT_VERSION_NON_AA_WC_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_THROTTLER_FACTORS_FOR_SEP_RT_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_UNSUB_AFTER_BATCHPUSH;
import static com.linkedin.venice.ConfigKeys.SERVER_ZSTD_DICT_COMPRESSION_LEVEL;
import static com.linkedin.venice.ConfigKeys.SEVER_CALCULATE_QUOTA_USAGE_BASED_ON_PARTITIONS_ASSIGNMENT_ENABLED;
Expand Down Expand Up @@ -554,14 +554,14 @@ public class VeniceServerConfig extends VeniceClusterConfig {
private final int consumerPoolSizeForNonCurrentVersionAAWCLeader;
private final int consumerPoolSizeForCurrentVersionNonAAWCLeader;
private final int consumerPoolSizeForNonCurrentVersionNonAAWCLeader;
private final List<Double> consumerPoolRecordsLimitFactorsForCurrentVersionAAWCLeader;
private final List<Double> consumerPoolRecordsLimitFactorsForCurrentVersionNonAAWCLeader;
private final List<Double> consumerPoolRecordsLimitFactorsForCurrentVersionSepRTLeader;
private final List<Double> consumerPoolRecordsLimitFactorsForNonCurrentVersionAAWCLeader;
private final List<Double> consumerPoolRecordsLimitFactorsForNonCurrentVersionNonAAWCLeader;
private final List<Double> kafkaFetchQuotaRecordsFactorsPerSecond;
private final List<Double> dedicatedConsumerPoolRecordsLimitFactorsForAAWCLeader;
private final List<Double> dedicatedConsumerPoolRecordsLimitFactorsForSepRTLeader;
private final List<Double> throttlerFactorsForCurrentVersionAAWCLeader;
private final List<Double> throttlerFactorsForCurrentVersionNonAAWCLeader;
private final List<Double> throttlerFactorsForCurrentVersionSepRTLeader;
private final List<Double> throttlerFactorsForNonCurrentVersionAAWCLeader;
private final List<Double> throttlerFactorsForNonCurrentVersionNonAAWCLeader;
private final List<Double> kafkaFetchThrottlerFactorsPerSecond;
private final List<Double> throttlerFactorsForAAWCLeader;
private final List<Double> throttlerFactorsForSepRTLeader;
private final int dedicatedConsumerPoolSizeForAAWCLeader;
private final int dedicatedConsumerPoolSizeForSepRTLeader;
private final boolean useDaVinciSpecificExecutionStatusForError;
Expand Down Expand Up @@ -884,9 +884,7 @@ public VeniceServerConfig(VeniceProperties serverProperties, Map<String, Map<Str
ingestionMlockEnabled = serverProperties.getBoolean(INGESTION_MLOCK_ENABLED, false);
if (!serverProperties.getString(INGESTION_MEMORY_LIMIT_STORE_LIST, "").isEmpty()) {
ingestionMemoryLimitStoreSet =
serverProperties.getList(INGESTION_MEMORY_LIMIT_STORE_LIST, Collections.emptyList())
.stream()
.collect(Collectors.toSet());
new HashSet<>(serverProperties.getList(INGESTION_MEMORY_LIMIT_STORE_LIST, Collections.emptyList()));
} else {
ingestionMemoryLimitStoreSet = Collections.emptySet();
}
Expand Down Expand Up @@ -931,30 +929,24 @@ public VeniceServerConfig(VeniceProperties serverProperties, Map<String, Map<Str
consumerPoolSizeForCurrentVersionAAWCLeader =
serverProperties.getInt(SERVER_CONSUMER_POOL_SIZE_FOR_CURRENT_VERSION_AA_WC_LEADER, 10);

kafkaFetchQuotaRecordsFactorsPerSecond =
extractThrottleLimitFactorsFor(serverProperties, KAFKA_FETCH_QUOTA_RECORDS_FACTORS_PER_SECOND);
dedicatedConsumerPoolRecordsLimitFactorsForAAWCLeader = extractThrottleLimitFactorsFor(
kafkaFetchThrottlerFactorsPerSecond =
extractThrottleLimitFactorsFor(serverProperties, KAFKA_FETCH_THROTTLER_FACTORS_PER_SECOND);
throttlerFactorsForAAWCLeader =
extractThrottleLimitFactorsFor(serverProperties, SERVER_THROTTLER_FACTORS_FOR_AA_WC_LEADER);
throttlerFactorsForSepRTLeader =
extractThrottleLimitFactorsFor(serverProperties, SERVER_THROTTLER_FACTORS_FOR_SEP_RT_LEADER);
throttlerFactorsForCurrentVersionAAWCLeader =
extractThrottleLimitFactorsFor(serverProperties, SERVER_THROTTLER_FACTORS_FOR_CURRENT_VERSION_AA_WC_LEADER);
throttlerFactorsForCurrentVersionNonAAWCLeader =
extractThrottleLimitFactorsFor(serverProperties, SERVER_THROTTLER_FACTORS_FOR_CURRENT_VERSION_NON_AA_WC_LEADER);
throttlerFactorsForCurrentVersionSepRTLeader = extractThrottleLimitFactorsFor(
serverProperties,
SERVER_DEDICATED_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_AA_WC_LEADER);
dedicatedConsumerPoolRecordsLimitFactorsForSepRTLeader = extractThrottleLimitFactorsFor(
SERVER_THROTTLER_FACTORS_FOR_CURRENT_VERSION_SEPARATE_RT_LEADER);
throttlerFactorsForNonCurrentVersionAAWCLeader =
extractThrottleLimitFactorsFor(serverProperties, SERVER_THROTTLER_FACTORS_FOR_NON_CURRENT_VERSION_AA_WC_LEADER);
throttlerFactorsForNonCurrentVersionNonAAWCLeader = extractThrottleLimitFactorsFor(
serverProperties,
SERVER_DEDICATED_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_SEP_RT_LEADER);

consumerPoolRecordsLimitFactorsForCurrentVersionAAWCLeader = extractThrottleLimitFactorsFor(
serverProperties,
SERVER_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_CURRENT_VERSION_AA_WC_LEADER);
consumerPoolRecordsLimitFactorsForCurrentVersionNonAAWCLeader = extractThrottleLimitFactorsFor(
serverProperties,
SERVER_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_CURRENT_VERSION_NON_AA_WC_LEADER);
consumerPoolRecordsLimitFactorsForCurrentVersionSepRTLeader = extractThrottleLimitFactorsFor(
serverProperties,
SERVER_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_CURRENT_VERSION_SEPARATE_RT_LEADER);
consumerPoolRecordsLimitFactorsForNonCurrentVersionAAWCLeader = extractThrottleLimitFactorsFor(
serverProperties,
SERVER_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_NON_CURRENT_VERSION_AA_WC_LEADER);
consumerPoolRecordsLimitFactorsForNonCurrentVersionNonAAWCLeader = extractThrottleLimitFactorsFor(
serverProperties,
SERVER_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_NON_CURRENT_VERSION_NON_AA_WC_LEADER);
SERVER_THROTTLER_FACTORS_FOR_NON_CURRENT_VERSION_NON_AA_WC_LEADER);

consumerPoolSizeForCurrentVersionSepRTLeader =
serverProperties.getInt(SERVER_CONSUMER_POOL_SIZE_FOR_CURRENT_VERSION_SEPARATE_RT_LEADER, 10);
Expand Down Expand Up @@ -1636,36 +1628,36 @@ public boolean getBatchReportEOIPEnabled() {
return batchReportEOIPEnabled;
}

public List<Double> getConsumerPoolRecordsLimitFactorsForCurrentVersionAAWCLeader() {
return consumerPoolRecordsLimitFactorsForCurrentVersionAAWCLeader;
public List<Double> getThrottlerFactorsForCurrentVersionAAWCLeader() {
return throttlerFactorsForCurrentVersionAAWCLeader;
}

public List<Double> getConsumerPoolRecordsLimitFactorsForCurrentVersionNonAAWCLeader() {
return consumerPoolRecordsLimitFactorsForCurrentVersionNonAAWCLeader;
public List<Double> getThrottlerFactorsForCurrentVersionNonAAWCLeader() {
return throttlerFactorsForCurrentVersionNonAAWCLeader;
}

public List<Double> getConsumerPoolRecordsLimitFactorsForCurrentVersionSepRTLeader() {
return consumerPoolRecordsLimitFactorsForCurrentVersionSepRTLeader;
public List<Double> getThrottlerFactorsForCurrentVersionSepRTLeader() {
return throttlerFactorsForCurrentVersionSepRTLeader;
}

public List<Double> getConsumerPoolRecordsLimitFactorsForNonCurrentVersionAAWCLeader() {
return consumerPoolRecordsLimitFactorsForNonCurrentVersionAAWCLeader;
public List<Double> getThrottlerFactorsForNonCurrentVersionAAWCLeader() {
return throttlerFactorsForNonCurrentVersionAAWCLeader;
}

public List<Double> getConsumerPoolRecordsLimitFactorsForNonCurrentVersionNonAAWCLeader() {
return consumerPoolRecordsLimitFactorsForNonCurrentVersionNonAAWCLeader;
public List<Double> getThrottlerFactorsForNonCurrentVersionNonAAWCLeader() {
return throttlerFactorsForNonCurrentVersionNonAAWCLeader;
}

public List<Double> getKafkaFetchQuotaRecordsFactorsPerSecond() {
return kafkaFetchQuotaRecordsFactorsPerSecond;
public List<Double> getKafkaFetchThrottlerFactorsPerSecond() {
return kafkaFetchThrottlerFactorsPerSecond;
}

public List<Double> getDedicatedConsumerPoolRecordsLimitFactorsForAAWCLeader() {
return dedicatedConsumerPoolRecordsLimitFactorsForAAWCLeader;
public List<Double> getThrottlerFactorsForAAWCLeader() {
return throttlerFactorsForAAWCLeader;
}

public List<Double> getDedicatedConsumerPoolRecordsLimitFactorsForSepRTLeader() {
return dedicatedConsumerPoolRecordsLimitFactorsForSepRTLeader;
public List<Double> getThrottlerFactorsForSepRTLeader() {
return throttlerFactorsForSepRTLeader;
}

public enum IncrementalPushStatusWriteMode {
Expand Down
4 changes: 2 additions & 2 deletions ...da-vinci-client/src/main/java/com/linkedin/davinci/kafka/consumer/IngestionThrottler.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,7 @@ public IngestionThrottler(
globalRecordAdaptiveIngestionThrottler = new VeniceAdaptiveIngestionThrottler(
serverConfig.getAdaptiveThrottlerSignalIdleThreshold(),
serverConfig.getKafkaFetchQuotaRecordPerSecond(),
serverConfig.getKafkaFetchQuotaRecordsFactorsPerSecond(),
serverConfig.getKafkaFetchThrottlerFactorsPerSecond(),
serverConfig.getKafkaFetchQuotaTimeWindow(),
"kafka_consumption_records_count");
globalRecordAdaptiveIngestionThrottler
Expand All @@ -81,7 +81,7 @@ public IngestionThrottler(
globalBandwidthAdaptiveIngestionThrottler = new VeniceAdaptiveIngestionThrottler(
serverConfig.getAdaptiveThrottlerSignalIdleThreshold(),
serverConfig.getKafkaFetchQuotaBytesPerSecond(),
serverConfig.getKafkaFetchQuotaRecordsFactorsPerSecond(),
serverConfig.getKafkaFetchThrottlerFactorsPerSecond(),
serverConfig.getKafkaFetchQuotaTimeWindow(),
"kafka_consumption_bandwidth");
globalBandwidthAdaptiveIngestionThrottler
Expand Down
42 changes: 18 additions & 24 deletions ...nts/da-vinci-client/src/test/java/com/linkedin/davinci/config/VeniceServerConfigTest.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -8,15 +8,15 @@
import static com.linkedin.venice.ConfigKeys.INGESTION_MEMORY_LIMIT;
import static com.linkedin.venice.ConfigKeys.INGESTION_USE_DA_VINCI_CLIENT;
import static com.linkedin.venice.ConfigKeys.KAFKA_BOOTSTRAP_SERVERS;
import static com.linkedin.venice.ConfigKeys.KAFKA_FETCH_QUOTA_RECORDS_FACTORS_PER_SECOND;
import static com.linkedin.venice.ConfigKeys.SERVER_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_CURRENT_VERSION_AA_WC_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_CURRENT_VERSION_NON_AA_WC_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_NON_CURRENT_VERSION_AA_WC_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_NON_CURRENT_VERSION_NON_AA_WC_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_DEDICATED_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_AA_WC_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_DEDICATED_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_SEP_RT_LEADER;
import static com.linkedin.venice.ConfigKeys.KAFKA_FETCH_THROTTLER_FACTORS_PER_SECOND;
import static com.linkedin.venice.ConfigKeys.SERVER_FORKED_PROCESS_JVM_ARGUMENT_LIST;
import static com.linkedin.venice.ConfigKeys.SERVER_INGESTION_MODE;
import static com.linkedin.venice.ConfigKeys.SERVER_THROTTLER_FACTORS_FOR_AA_WC_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_THROTTLER_FACTORS_FOR_CURRENT_VERSION_AA_WC_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_THROTTLER_FACTORS_FOR_CURRENT_VERSION_NON_AA_WC_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_THROTTLER_FACTORS_FOR_NON_CURRENT_VERSION_AA_WC_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_THROTTLER_FACTORS_FOR_NON_CURRENT_VERSION_NON_AA_WC_LEADER;
import static com.linkedin.venice.ConfigKeys.SERVER_THROTTLER_FACTORS_FOR_SEP_RT_LEADER;
import static com.linkedin.venice.ConfigKeys.ZOOKEEPER_ADDRESS;
import static org.testng.Assert.assertEquals;
import static org.testng.Assert.assertTrue;
Expand Down Expand Up @@ -65,29 +65,23 @@ public void testConfig() {

Map<String, Function<VeniceServerConfig, List<Double>>> configMap = new HashMap<>();

configMap.put(
KAFKA_FETCH_QUOTA_RECORDS_FACTORS_PER_SECOND,
VeniceServerConfig::getKafkaFetchQuotaRecordsFactorsPerSecond);
configMap.put(KAFKA_FETCH_THROTTLER_FACTORS_PER_SECOND, VeniceServerConfig::getKafkaFetchThrottlerFactorsPerSecond);

configMap.put(
SERVER_DEDICATED_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_AA_WC_LEADER,
VeniceServerConfig::getDedicatedConsumerPoolRecordsLimitFactorsForAAWCLeader);
configMap.put(
SERVER_DEDICATED_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_SEP_RT_LEADER,
VeniceServerConfig::getDedicatedConsumerPoolRecordsLimitFactorsForSepRTLeader);
configMap.put(SERVER_THROTTLER_FACTORS_FOR_AA_WC_LEADER, VeniceServerConfig::getThrottlerFactorsForAAWCLeader);
configMap.put(SERVER_THROTTLER_FACTORS_FOR_SEP_RT_LEADER, VeniceServerConfig::getThrottlerFactorsForSepRTLeader);

configMap.put(
SERVER_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_CURRENT_VERSION_AA_WC_LEADER,
VeniceServerConfig::getConsumerPoolRecordsLimitFactorsForCurrentVersionAAWCLeader);
SERVER_THROTTLER_FACTORS_FOR_CURRENT_VERSION_AA_WC_LEADER,
VeniceServerConfig::getThrottlerFactorsForCurrentVersionAAWCLeader);
configMap.put(
SERVER_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_CURRENT_VERSION_NON_AA_WC_LEADER,
VeniceServerConfig::getConsumerPoolRecordsLimitFactorsForCurrentVersionNonAAWCLeader);
SERVER_THROTTLER_FACTORS_FOR_CURRENT_VERSION_NON_AA_WC_LEADER,
VeniceServerConfig::getThrottlerFactorsForCurrentVersionNonAAWCLeader);
configMap.put(
SERVER_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_NON_CURRENT_VERSION_AA_WC_LEADER,
VeniceServerConfig::getConsumerPoolRecordsLimitFactorsForNonCurrentVersionAAWCLeader);
SERVER_THROTTLER_FACTORS_FOR_NON_CURRENT_VERSION_AA_WC_LEADER,
VeniceServerConfig::getThrottlerFactorsForNonCurrentVersionAAWCLeader);
configMap.put(
SERVER_CONSUMER_POOL_RECORDS_LIMIT_FACTORS_FOR_NON_CURRENT_VERSION_NON_AA_WC_LEADER,
VeniceServerConfig::getConsumerPoolRecordsLimitFactorsForNonCurrentVersionNonAAWCLeader);
SERVER_THROTTLER_FACTORS_FOR_NON_CURRENT_VERSION_NON_AA_WC_LEADER,
VeniceServerConfig::getThrottlerFactorsForNonCurrentVersionNonAAWCLeader);

// Looping through all the factors config keys and checking if the values are same as default values
for (Map.Entry<String, Function<VeniceServerConfig, List<Double>>> entry: configMap.entrySet()) {
Expand Down
Loading

0 comments on commit 754eb1c

Please sign in to comment.