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. ---