[ https://issues.apache.org/jira/browse/FLINK-9124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16423485#comment-16423485 ]
ASF GitHub Bot commented on FLINK-9124: --------------------------------------- GitHub user tweise opened a pull request: https://github.com/apache/flink/pull/5803 [FLINK-9124] [kinesis] Allow customization of KinesisProxy.getRecords read timeout and retry. ## What is the purpose of the change This pull request enables overrides for the AWS ClientConfiguration and getRecords retry in KinesisProxy. ## Brief change log - option to override retry for any SdkClientException - option to customize the ClientConfiguration used to construct the Kinesis client ## Verifying this change This change added tests and can be verified as follows: Added test to verify the configuration override. ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or upgrade a dependency): (yes / **no**) - The public API, i.e., is any changed class annotated with `@Public(Evolving)`: (yes / **no**) - The serializers: (yes / **no** / don't know) - The runtime per-record code paths (performance sensitive): (yes / **no** / don't know) - Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Yarn/Mesos, ZooKeeper: (yes / **no** / don't know) - The S3 file system connector: (yes / **no** / don't know) ## Documentation - Does this pull request introduce a new feature? (yes / **no**) - If yes, how is the feature documented? (not applicable / docs / JavaDocs / not documented) You can merge this pull request into a Git repository by running: $ git pull https://github.com/tweise/flink FLINK-9124.Kinesis.getRecords Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/5803.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #5803 ---- commit 563763fa6eb6eede1654a6b157a1b006b360731d Author: Thomas Weise <thw@...> Date: 2018-04-03T03:49:50Z [FLINK-9124] Allow customization of KinesisProxy.getRecords read timeout and retry. ---- > Allow customization of KinesisProxy.getRecords read timeout and retry > --------------------------------------------------------------------- > > Key: FLINK-9124 > URL: https://issues.apache.org/jira/browse/FLINK-9124 > Project: Flink > Issue Type: Task > Components: Kinesis Connector > Affects Versions: 1.4.2 > Reporter: Thomas Weise > Assignee: Thomas Weise > Priority: Minor > > It should be possible to change the socket read timeout and all other > configuration parameters of the underlying AWS ClientConfiguration and also > have the option to retry after a socket timeout exception. -- This message was sent by Atlassian JIRA (v7.6.3#76005)