You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "ASF GitHub Bot (Jira)" <ji...@apache.org> on 2024/11/06 17:33:00 UTC
[jira] [Updated] (FLINK-36668) Release flink-connector-aws v5.0.0
[ https://issues.apache.org/jira/browse/FLINK-36668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
ASF GitHub Bot updated FLINK-36668:
-----------------------------------
Labels: pull-request-available (was: )
> Release flink-connector-aws v5.0.0
> ----------------------------------
>
> Key: FLINK-36668
> URL: https://issues.apache.org/jira/browse/FLINK-36668
> Project: Flink
> Issue Type: Technical Debt
> Reporter: Hong Liang Teoh
> Priority: Major
> Labels: pull-request-available
>
> Release flink-connector-aws v5.0.0
>
> This is needed because of breaking changes made for the Table API Kinesis Source in {*}flink-connector-kinesis{*}.
> This breaking change cannot be avoided because the new source/sink are being created in {*}flink-connector-aws-kinesis-streams{*}, which is a dependency of *flink-connector-kinesis* (old source/sink).
>
> As such, the moment we introduce a new TableFactory for new source in {*}flink-connector-aws-kinesis-streams{*}, it will immediately conflict with the existing TableFactory in {*}flink-connector-kinesis{*}.
>
> To resolve this, but still allow users to use the old Table API if needed, we changed the identifier for the old source to {*}kinesis-legacy{*}.
>
> This means that for Table API, the state is not compatible for *kinesis.*
--
This message was sent by Atlassian Jira
(v8.20.10#820010)