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

Updated comment removed one variable for consistency

Browse source
This commit is contained in:
eha sah 2025-04-08 19:38:21 -07:00
parent c17118429e
commit 57868a28e1
2 changed files with 2 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -433,7 +433,7 @@ class LeaseAssignmentManagerTest {
.anyMatch(lease -> lease.leaseOwner().equals(TEST_YIELD_WORKER_ID + "2"))); .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 // @Test
void performAssignment_varianceBalanceFreq3_asserLoadBalancingEvery3Iteration() throws Exception { void performAssignment_varianceBalanceFreq3_asserLoadBalancingEvery3Iteration() throws Exception {
final LeaseManagementConfig.WorkerUtilizationAwareAssignmentConfig config = final LeaseManagementConfig.WorkerUtilizationAwareAssignmentConfig config =

3
amazon-kinesis-client/src/test/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseCoordinatorIntegrationTest.java
View file

@ -71,7 +71,6 @@ public class DynamoDBLeaseCoordinatorIntegrationTest {
private static DynamoDBLeaseRefresher leaseRefresher; private static DynamoDBLeaseRefresher leaseRefresher;
private static DynamoDBCheckpointer dynamoDBCheckpointer; private static DynamoDBCheckpointer dynamoDBCheckpointer;
private static final long LEASE_ASSIGNMENT_INTERVAL_MILLIS = 2 * LEASE_DURATION_MILLIS;
private LeaseCoordinator coordinator; private LeaseCoordinator coordinator;
private final String leaseKey = "shd-1"; private final String leaseKey = "shd-1";
@ -130,7 +129,7 @@ public class DynamoDBLeaseCoordinatorIntegrationTest {
new LeaseManagementConfig.WorkerUtilizationAwareAssignmentConfig(), new LeaseManagementConfig.WorkerUtilizationAwareAssignmentConfig(),
LeaseManagementConfig.GracefulLeaseHandoffConfig.builder().build(), LeaseManagementConfig.GracefulLeaseHandoffConfig.builder().build(),
new ConcurrentHashMap<>(), new ConcurrentHashMap<>(),
LEASE_ASSIGNMENT_INTERVAL_MILLIS); 2 * LEASE_DURATION_MILLIS);
dynamoDBCheckpointer = new DynamoDBCheckpointer(coordinator, leaseRefresher); dynamoDBCheckpointer = new DynamoDBCheckpointer(coordinator, leaseRefresher);
dynamoDBCheckpointer.operation(OPERATION); dynamoDBCheckpointer.operation(OPERATION);