From 8d40e5bdd40c6738b633b7451944c0dd4d08c904 Mon Sep 17 00:00:00 2001
From: Ashwin Giridharan <girida@amazon.com>
Date: Wed, 17 Jun 2020 10:49:57 -0700
Subject: [PATCH] Skipping ddb scan and shard sync for streams that has no
 shards returned from service

---
 .../amazon/kinesis/leases/HierarchicalShardSyncer.java         | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/HierarchicalShardSyncer.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/HierarchicalShardSyncer.java
index 5c18ee85..b3cfdb56 100644
--- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/HierarchicalShardSyncer.java
+++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/HierarchicalShardSyncer.java
@@ -129,6 +129,9 @@ public class HierarchicalShardSyncer {
 
         if (!CollectionUtils.isNullOrEmpty(latestShards)) {
             log.debug("{} - Num shards: {}", streamIdentifier, latestShards.size());
+        } else {
+            log.warn("Skipping shard sync for {} as no shards found from service.", streamIdentifier);
+            return;
         }
 
         final Map<String, Shard> shardIdToShardMap = constructShardIdToShardMap(latestShards);