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

Fixing condition check

Browse source
This commit is contained in:
Ashwin Giridharan 2020-06-24 14:34:01 -07:00
parent b636edd007
commit 950faf7475
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShutdownTask.java
View file

@ -144,7 +144,7 @@ public class ShutdownTask implements ConsumerTask {
// if childshards is empty. When child shards is empty then either it is due to // if childshards is empty. When child shards is empty then either it is due to
// completed shard being reprocessed or we got RNF from service. // completed shard being reprocessed or we got RNF from service.
// For these cases enqueue the lease for deletion. // For these cases enqueue the lease for deletion.
if (isSuccess || !CollectionUtils.isNullOrEmpty(childShards)) { if (isSuccess || CollectionUtils.isNullOrEmpty(childShards)) {
leaseCleanupManager.enqueueForDeletion(leasePendingDeletion); leaseCleanupManager.enqueueForDeletion(leasePendingDeletion);
} }
} }