Github user skidder commented on the issue:
https://github.com/apache/flink/pull/3078
Thanks @tzulitai , great feedback!
The `ProvisionedThroughputExceededException` exception will be reported
with an HTTP 400 response status code:
http://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetRecords.html#API_GetRecords_Errors
The AWS SDK will assign the `ErrorType.Client` type to all exceptions with
an HTTP status code less than 500 ([AWS SDK
source](https://github.com/aws/aws-sdk-java/blob/7844c64cf248aed889811bf2e871ad6b276a89ca/aws-java-sdk-core/src/main/java/com/amazonaws/http/JsonErrorResponseHandler.java#L119-L121)).
Perhaps we can perform exponential-backoff for exceptions where:
* `Client` error of type `ProvisionedThroughputExceededException`
* All `Server` errors (e.g. HTTP 500, 503)
* All `Unknown` errors (appear to be limited to errors unmarshalling the
Kinesis service response)
All other exceptions can be thrown up.
What are your thoughts?
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
