Fixing bug where ShardFilter parameter for ListShards was being passe…

…d in for paginated calls. (#790) Co-authored-by: Joshua Kim <kimjos@amazon.com>
awslabs · Feb 24, 2021 · a13ed13 · a13ed13
1 parent b4f6f8f
commit a13ed13
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/src/main/java/com/amazonaws/services/kinesis/clientlibrary/proxies/KinesisProxy.java b/src/main/java/com/amazonaws/services/kinesis/clientlibrary/proxies/KinesisProxy.java
@@ -315,13 +315,12 @@ private ListShardsResult listShards(final ShardFilter shardFilter, final String
         request.setRequestCredentials(credentialsProvider.getCredentials());
         if (StringUtils.isEmpty(nextToken)) {
             request.setStreamName(streamName);
+            request.setShardFilter(shardFilter);
         } else {
             request.setNextToken(nextToken);
         }
 
-        if (shardFilter != null) {
-            request.setShardFilter(shardFilter);
-        }
+        LOG.info("Listing shards with list shards request " + request);
 
         ListShardsResult result = null;
         LimitExceededException lastException = null;