tweise commented on a change in pull request #7706: [FLINK-11617] [kinesis connector] Kinesis Connector getRecords() failure logging is misleading URL: https://github.com/apache/flink/pull/7706#discussion_r257053063
########## File path: flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/proxy/KinesisProxy.java ########## @@ -262,8 +262,8 @@ public GetRecordsResult getRecords(String shardIterator, int maxRecordsToGet) th } if (getRecordsResult == null) { - throw new RuntimeException("Rate Exceeded for getRecords operation - all " + getRecordsMaxRetries + - " retry attempts returned ProvisionedThroughputExceededException."); + throw new RuntimeException("Retries exceeded for getRecords operation - all " + getRecordsMaxRetries + Review comment: Please also fix same issue further down in `getShardIterator` (https://github.com/apache/flink/pull/7706/files#diff-ed02b5340df65de06c19eb93fe90a920L340) ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services