[FLINK-10020] Kinesis Consumer listShards should support more recoverable exceptions

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.6.1, 1.7.0
• Component/s: Connectors / Kinesis
• Labels: pull-request-available
• Assignee: Thomas Weise
• Reporter: Thomas Weise
• Created: 01/Aug/18 21:24
• Updated: 17/Aug/18 05:26
• Resolved: 17/Aug/18 05:26

Description

Currently transient errors in listShards make the consumer fail and cause the entire job to reset. That is unnecessary for certain exceptions (like status 503 errors). It should be possible to control the exceptions that qualify for retry, similar to getRecords/isRecoverableSdkClientException.

Issue Links

• links to: GitHub Pull Request #6482