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

Changed variance based balancing to 12

Browse source
This commit is contained in:
eha sah 2025-04-10 09:41:06 -07:00
parent f9465637ae
commit cc0bf011a0
3 changed files with 4 additions and 4 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(
6, 12,
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 sixth (as default) iteration of LAM the worker variance balancing will be performed. * that is every twelfth (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 = 6; private int varianceBalancingFrequency = 12;
/** /**
* 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

2
amazon-kinesis-client/src/test/java/software/amazon/kinesis/coordinator/assignment/LeaseAssignmentManagerTest.java
View file

@ -789,7 +789,7 @@ class LeaseAssignmentManagerTest {
LeaseManagementConfig.GracefulLeaseHandoffConfig.builder() LeaseManagementConfig.GracefulLeaseHandoffConfig.builder()
.isGracefulLeaseHandoffEnabled(false) .isGracefulLeaseHandoffEnabled(false)
.build(), .build(),
100L); 200L);
leaseAssignmentManager.start(); leaseAssignmentManager.start();