From 57868a28e11f19354116d9b2bbb71808e9030cac Mon Sep 17 00:00:00 2001 From: eha sah Date: Tue, 8 Apr 2025 19:38:21 -0700 Subject: [PATCH] Updated comment removed one variable for consistency --- .../coordinator/assignment/LeaseAssignmentManagerTest.java | 2 +- .../dynamodb/DynamoDBLeaseCoordinatorIntegrationTest.java | 3 +-- 2 files changed, 2 insertions(+), 3 deletions(-) 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);