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

Bug fix for cleanupLease logic -- not check child shards when cleanup is disabled

Browse source
This commit is contained in:
Qilin Jin 2022-04-28 14:30:56 -07:00
parent 8dceb3f80f
commit b1cc74ee4a
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/main/java/com/amazonaws/services/kinesis/leases/impl/LeaseCleanupManager.java
View file

@ -238,7 +238,7 @@ public class LeaseCleanupManager {
} else { } else {
cleanupFailureReason = "Configuration/Interval condition not satisfied to execute lease cleanup this cycle"; cleanupFailureReason = "Configuration/Interval condition not satisfied to execute lease cleanup this cycle";
} }
if (!cleanedUpCompletedLease && !alreadyCheckedForGarbageCollection && timeToCheckForGarbageShard) { if (cleanupLeasesUponShardCompletion && !cleanedUpCompletedLease && !alreadyCheckedForGarbageCollection && timeToCheckForGarbageShard) {
// throws ResourceNotFoundException // throws ResourceNotFoundException
wereChildShardsPresent = !CollectionUtils wereChildShardsPresent = !CollectionUtils
.isNullOrEmpty(getChildShardsFromService(shardInfo)); .isNullOrEmpty(getChildShardsFromService(shardInfo));