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 5e27ffcc..cc417dc9 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 @@ -433,7 +433,7 @@ class LeaseAssignmentManagerTest { .anyMatch(lease -> lease.leaseOwner().equals(TEST_YIELD_WORKER_ID + "2"))); } - // no needed since variance based load balancing is not longed tied to LAM run + // no needed since variance based load balancing is no longer tied to LAM run // @Test void performAssignment_varianceBalanceFreq3_asserLoadBalancingEvery3Iteration() throws Exception { final LeaseManagementConfig.WorkerUtilizationAwareAssignmentConfig config = diff --git a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseCoordinatorIntegrationTest.java b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseCoordinatorIntegrationTest.java index 400310a7..b90f3a5d 100644 --- a/amazon-kinesis-client/src/test/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseCoordinatorIntegrationTest.java +++ b/amazon-kinesis-client/src/test/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseCoordinatorIntegrationTest.java @@ -71,7 +71,6 @@ public class DynamoDBLeaseCoordinatorIntegrationTest { private static DynamoDBLeaseRefresher leaseRefresher; private static DynamoDBCheckpointer dynamoDBCheckpointer; - private static final long LEASE_ASSIGNMENT_INTERVAL_MILLIS = 2 * LEASE_DURATION_MILLIS; private LeaseCoordinator coordinator; private final String leaseKey = "shd-1"; @@ -130,7 +129,7 @@ public class DynamoDBLeaseCoordinatorIntegrationTest { new LeaseManagementConfig.WorkerUtilizationAwareAssignmentConfig(), LeaseManagementConfig.GracefulLeaseHandoffConfig.builder().build(), new ConcurrentHashMap<>(), - LEASE_ASSIGNMENT_INTERVAL_MILLIS); + 2 * LEASE_DURATION_MILLIS); dynamoDBCheckpointer = new DynamoDBCheckpointer(coordinator, leaseRefresher); dynamoDBCheckpointer.operation(OPERATION);