You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Hong Liang Teoh (Jira)" <ji...@apache.org> on 2024/11/06 17:27:00 UTC

[jira] [Created] (FLINK-36668) Release flink-connector-aws v5.0.0

Hong Liang Teoh created FLINK-36668:
---------------------------------------

             Summary: 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


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)