From a13ed13702e27e200a9c8e079c66f486034b0a03 Mon Sep 17 00:00:00 2001 From: Joshua Kim <20001595+joshua-kim@users.noreply.github.com> Date: Wed, 24 Feb 2021 13:34:39 -0800 Subject: [PATCH] Fixing bug where ShardFilter parameter for ListShards was being passed in for paginated calls. (#790) Co-authored-by: Joshua Kim --- .../services/kinesis/clientlibrary/proxies/KinesisProxy.java | 5 ++--- 1 file changed, 2 insertions(+), 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 index 0936bddb..c1d7f10d 100644 --- 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 @@ public class KinesisProxy implements IKinesisProxyExtended { 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;