luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Changed variance based balancing to 3

Browse source
This commit is contained in:
eha sah 2025-04-10 10:22:13 -07:00
parent cc0bf011a0
commit 90b1282d16
2 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
amazon-kinesis-client-multilang/src/test/java/software/amazon/kinesis/multilang/config/PropertiesMappingE2ETest.java
View file

@ -249,7 +249,7 @@ public class PropertiesMappingE2ETest {
.workerUtilizationAwareAssignmentConfig() .workerUtilizationAwareAssignmentConfig()
.staleWorkerMetricsEntryCleanupDuration()); .staleWorkerMetricsEntryCleanupDuration());
assertEquals( assertEquals(
12, 3,
kclV3Config kclV3Config
.leaseManagementConfig .leaseManagementConfig
.workerUtilizationAwareAssignmentConfig() .workerUtilizationAwareAssignmentConfig()

4
amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseManagementConfig.java
View file

@ -580,12 +580,12 @@ public class LeaseManagementConfig {
/** /**
* Frequency to perform worker variance balancing. This value is used with respect to the LAM frequency, * Frequency to perform worker variance balancing. This value is used with respect to the LAM frequency,
* that is every twelfth (as default) iteration of LAM the worker variance balancing will be performed. * that is every third (as default) iteration of LAM the worker variance balancing will be performed.
* Setting it to 1 will make varianceBalancing run on every iteration of LAM and 2 on every 2nd iteration * Setting it to 1 will make varianceBalancing run on every iteration of LAM and 2 on every 2nd iteration
* and so on. * and so on.
* NOTE: LAM frequency = failoverTimeMillis * NOTE: LAM frequency = failoverTimeMillis
*/ */
private int varianceBalancingFrequency = 12; private int varianceBalancingFrequency = 3;
/** /**
* Alpha value used for calculating exponential moving average of worker's metricStats. Selecting * Alpha value used for calculating exponential moving average of worker's metricStats. Selecting