From a85ef70898984fe8dfeaeffa6ec7f8d82fdae36d Mon Sep 17 00:00:00 2001 From: Joshua Kim Date: Fri, 7 Aug 2020 15:07:10 -0400 Subject: [PATCH] Fixing list shards bug --- .../kinesis/clientlibrary/lib/worker/KinesisShardSyncer.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisShardSyncer.java b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisShardSyncer.java index 1ce1175a..4235bad9 100644 --- a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisShardSyncer.java +++ b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/lib/worker/KinesisShardSyncer.java @@ -169,7 +169,7 @@ class KinesisShardSyncer implements ShardSyncer { List shards; if(CollectionUtils.isNullOrEmpty(latestShards)) { - shards = getShardListAtInitialPosition(kinesisProxy, initialPosition); + shards = isLeaseTableEmpty ? getShardListAtInitialPosition(kinesisProxy, initialPosition) : getCompleteShardList(kinesisProxy); } else { shards = latestShards; }