From ea093a44660729e576b745591ebcde552ef3c98d Mon Sep 17 00:00:00 2001 From: Joshua Kim Date: Mon, 30 Mar 2020 19:30:11 -0400 Subject: [PATCH] Adding stream id to exception --- .../amazon/kinesis/leases/HierarchicalShardSyncer.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) 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 d398fb34..07521335 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 @@ -347,6 +347,8 @@ public class HierarchicalShardSyncer { InitialPositionInStreamExtended initialPositionInStreamExtended) throws KinesisClientLibIOException { final ShardFilter shardFilter = getShardFilterFromInitialPosition(initialPositionInStreamExtended); + final String streamName = shardDetector.streamIdentifier().streamName(); + List shards; for (int i = 0; i < retriesForCompleteHashRange; i++) { @@ -354,8 +356,7 @@ public class HierarchicalShardSyncer { if (shards == null) { throw new KinesisClientLibIOException( - "Stream " + shardDetector.streamIdentifier().streamName() + - " is not in ACTIVE OR UPDATING state - will retry getting the shard list."); + "Stream " + streamName + " is not in ACTIVE OR UPDATING state - will retry getting the shard list."); } if (hashRangeOfShardsIsComplete(shards)) { @@ -363,7 +364,7 @@ public class HierarchicalShardSyncer { } } - throw new KinesisClientLibIOException("Hash range of shards returned was incomplete after " + throw new KinesisClientLibIOException("Hash range of shards returned for " + streamName + " was incomplete after " + retriesForCompleteHashRange + " retries."); }