From 950faf74756b5f048841d8c2fcbb4e285865303d Mon Sep 17 00:00:00 2001 From: Ashwin Giridharan Date: Wed, 24 Jun 2020 14:34:01 -0700 Subject: [PATCH] Fixing condition check --- .../java/software/amazon/kinesis/lifecycle/ShutdownTask.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShutdownTask.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShutdownTask.java index d6282cff..91ea125b 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShutdownTask.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/lifecycle/ShutdownTask.java @@ -144,7 +144,7 @@ public class ShutdownTask implements ConsumerTask { // 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. // For these cases enqueue the lease for deletion. - if (isSuccess || !CollectionUtils.isNullOrEmpty(childShards)) { + if (isSuccess || CollectionUtils.isNullOrEmpty(childShards)) { leaseCleanupManager.enqueueForDeletion(leasePendingDeletion); } }