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 070757ec..dfd5e8e1 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( - 6, + 12, 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 445bcc3c..f678ec69 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 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 * and so on. * 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 diff --git a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/coordinator/assignment/LeaseAssignmentManagerTest.java b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/coordinator/assignment/LeaseAssignmentManagerTest.java index bc9e6620..5ebd33d8 100644 --- a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/coordinator/assignment/LeaseAssignmentManagerTest.java +++ b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/coordinator/assignment/LeaseAssignmentManagerTest.java @@ -789,7 +789,7 @@ class LeaseAssignmentManagerTest { LeaseManagementConfig.GracefulLeaseHandoffConfig.builder() .isGracefulLeaseHandoffEnabled(false) .build(), - 100L); + 200L); leaseAssignmentManager.start();