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

Update the warning when lease taker failed to fetch the latest state of the lease

Browse source
This commit is contained in:
Yu Zeng 2022-01-03 10:19:23 -08:00
parent 72aeac3819
commit a3e51d5595
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/dynamodb/DynamoDBLeaseTaker.java
View file

@ -64,7 +64,7 @@ public class DynamoDBLeaseTaker implements LeaseTaker {
private final long leaseDurationNanos;
private final long leaseRenewalIntervalMillis;
private final MetricsFactory metricsFactory;
final Map<String, Lease> allLeases = new HashMap<>();
// TODO: Remove these defaults and use the defaults in the config
private int maxLeasesForWorker = Integer.MAX_VALUE;
@ -260,8 +260,8 @@ public class DynamoDBLeaseTaker implements LeaseTaker {
try {
return leaseRefresher.getLease(lease.leaseKey());
} catch (DependencyException | InvalidStateException | ProvisionedThroughputException e) {
log.warn("Unable to retrieve the current lease while refreshing the stale lease, "
+ "defaulting to existing lease", e);
log.warn("Failed to fetch latest state of the lease {} that needs to be stolen, "
+ "defaulting to existing lease", lease.leaseKey(), e);
}
}
return lease;