luciano/amazon-kinesis-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Adding stream id to exception

Browse source
This commit is contained in:
Joshua Kim 2020-03-30 19:30:11 -04:00
parent 5351c9ddab
commit ea093a4466
1 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
amazon-kinesis-client/src/main/java/software/amazon/kinesis/leases/HierarchicalShardSyncer.java
View file

@ -347,6 +347,8 @@ public class HierarchicalShardSyncer {
InitialPositionInStreamExtended initialPositionInStreamExtended) throws KinesisClientLibIOException {
final ShardFilter shardFilter = getShardFilterFromInitialPosition(initialPositionInStreamExtended);
final String streamName = shardDetector.streamIdentifier().streamName();
List<Shard> 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.");
}