diff --git a/amazon-kinesis-client-multilang/src/test/java/software/amazon/kinesis/multilang/config/PropertiesMappingE2ETest.java b/amazon-kinesis-client-multilang/src/test/java/software/amazon/kinesis/multilang/config/PropertiesMappingE2ETest.java index dfd5e8e1..8a5c7c34 100644 --- a/amazon-kinesis-client-multilang/src/test/java/software/amazon/kinesis/multilang/config/PropertiesMappingE2ETest.java +++ b/amazon-kinesis-client-multilang/src/test/java/software/amazon/kinesis/multilang/config/PropertiesMappingE2ETest.java @@ -249,7 +249,7 @@ public class PropertiesMappingE2ETest { .workerUtilizationAwareAssignmentConfig() .staleWorkerMetricsEntryCleanupDuration()); assertEquals( - 12, + 3, kclV3Config .leaseManagementConfig .workerUtilizationAwareAssignmentConfig() diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseManagementConfig.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseManagementConfig.java index f678ec69..06104a9c 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseManagementConfig.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/LeaseManagementConfig.java @@ -580,12 +580,12 @@ public class LeaseManagementConfig { /** * 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 * and so on. * 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