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

added formating to avoid build failure

Browse source
This commit is contained in:
eha sah 2025-04-14 16:27:04 -07:00
parent 2f17a68b2a
commit e464302415
1 changed files with 1 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/assignment/LeaseAssignmentManager.java
View file

@ -124,10 +124,7 @@ public final class LeaseAssignmentManager {
// so reset the flag to refresh the state before processing during a restart of LAM. // so reset the flag to refresh the state before processing during a restart of LAM.
tookOverLeadershipInThisRun = false; tookOverLeadershipInThisRun = false;
managerFuture = executorService.scheduleWithFixedDelay( managerFuture = executorService.scheduleWithFixedDelay(
this::performAssignment, this::performAssignment, 0L, (int) (leaseAssignmentIntervalMillis), TimeUnit.MILLISECONDS);
0L,
(int) (leaseAssignmentIntervalMillis),
TimeUnit.MILLISECONDS);
log.info("Started LeaseAssignmentManager"); log.info("Started LeaseAssignmentManager");
return; return;
} }