[
https://issues.apache.org/jira/browse/FLINK-36972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hong Liang Teoh updated FLINK-36972:
------------------------------------
Fix Version/s: aws-connector-5.2.0
(was: aws-connector-5.1.0)
> Unify AWS sink implementation
> -----------------------------
>
> Key: FLINK-36972
> URL: https://issues.apache.org/jira/browse/FLINK-36972
> Project: Flink
> Issue Type: Technical Debt
> Components: Connectors / AWS
> Reporter: Ahmed Hamdy
> Priority: Major
> Fix For: aws-connector-5.2.0
>
>
> h1. Description
> AWS sinks (Kinesis, Firehose, DynamoDB, SQS) are all extensions of Async Sink
> API, all of these implementations are almost identical in regards of
> submitting request entries and fatal error handling and partial failure
> handling. The only difference is in the sdk client implementation. This
> causes simple changes to be replicated across all modules as in [this
> pr](https://github.com/apache/flink-connector-aws/pull/186/files)
> Ideally we want a common AWS sink writer with abstract client bean, different
> sink implementers would only provide client bean implementation with specific
> sdk clients while the common logic is unified.
> h2. Side effects
> - Some minor API changes might be required like changing
> {{DynamoDbSinkFailFastException}} and others to
> {{AwsAsyncSinkFailFastException}} and of course logging traces.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
