From 2f17a68b2ac2bbfb76219f284152d8e93e891d2c Mon Sep 17 00:00:00 2001 From: eha sah Date: Mon, 14 Apr 2025 16:12:56 -0700 Subject: [PATCH] Formating and remove unused variable --- .../assignment/LeaseAssignmentManager.java | 11 ++++------- 1 file changed, 4 insertions(+), 7 deletions(-) diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/assignment/LeaseAssignmentManager.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/assignment/LeaseAssignmentManager.java index 539c4cbe..00d38911 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/assignment/LeaseAssignmentManager.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/assignment/LeaseAssignmentManager.java @@ -80,12 +80,6 @@ public final class LeaseAssignmentManager { */ private static final int DEFAULT_FAILURE_COUNT_TO_SWITCH_LEADER = 3; - /** - * Default multiplier for LAM frequency with respect to leaseDurationMillis (lease failover millis). - * If leaseDurationMillis is 10000 millis, default LAM frequency is 20000 millis. - */ - private static final int DEFAULT_LEASE_ASSIGNMENT_MANAGER_FREQ_MULTIPLIER = 2; - private static final String FORCE_LEADER_RELEASE_METRIC_NAME = "ForceLeaderRelease"; /** @@ -130,7 +124,10 @@ public final class LeaseAssignmentManager { // so reset the flag to refresh the state before processing during a restart of LAM. tookOverLeadershipInThisRun = false; managerFuture = executorService.scheduleWithFixedDelay( - this::performAssignment, 0L, (int) (leaseAssignmentIntervalMillis), TimeUnit.MILLISECONDS); + this::performAssignment, + 0L, + (int) (leaseAssignmentIntervalMillis), + TimeUnit.MILLISECONDS); log.info("Started LeaseAssignmentManager"); return; }