From 27613763acec74c0a3af08331065d139b96dbe2f Mon Sep 17 00:00:00 2001 From: Chunxue Yang Date: Wed, 17 Jun 2020 11:31:22 -0700 Subject: [PATCH] search child shards in DDB instead of in local cache --- .../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 9743704d..d8496a91 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 @@ -246,7 +246,7 @@ public class ShutdownTask implements ConsumerTask { throws DependencyException, InvalidStateException, ProvisionedThroughputException { for(ChildShard childShard : childShards) { final String leaseKey = ShardInfo.getLeaseKey(shardInfo, childShard.shardId()); - if(leaseCoordinator.getCurrentlyHeldLease(leaseKey) == null) { + if(leaseCoordinator.leaseRefresher().getLease(leaseKey) == null) { final Lease leaseToCreate = hierarchicalShardSyncer.createLeaseForChildShard(childShard, shardDetector.streamIdentifier()); leaseCoordinator.leaseRefresher().createLeaseIfNotExists(leaseToCreate); log.info("Shard {}: Created child shard lease: {}", shardInfo.shardId(), leaseToCreate.leaseKey());