[
https://issues.apache.org/jira/browse/FLINK-39426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18085063#comment-18085063
]
Paras Negi commented on FLINK-39426:
------------------------------------
Investigated the connector ecosystem — restoring these interfaces in flink-core
isn't necessary. Every connector that implemented
{{{}StatefulSink{}}}/{{{}TwoPhaseCommittingSink{}}} is already covered:
* *Released for Flink 2.x:* Kafka (4.0.1-2.0), Elasticsearch (4.0.0-2.0), AWS
(6.0.0-2.0), JDBC-core (4.0.0-2.0)
* *Migrated, release pending:* OpenSearch, MongoDB
* *Migration in progress:* Pulsar — the only connector still implementing
{{TwoPhaseCommittingSink}} on main, being migrated in [PR
#123|https://github.com/apache/flink-connector-pulsar/pull/123]
The correct fix is the per-connector migration rather than reintroducing
deprecated APIs in Flink 2.x.
> Flink 2.0 and Connector version compatibility issue
> ---------------------------------------------------
>
> Key: FLINK-39426
> URL: https://issues.apache.org/jira/browse/FLINK-39426
> Project: Flink
> Issue Type: Bug
> Components: API / Core
> Affects Versions: 2.2.0
> Environment: dev
> Reporter: Xueyan Wang
> Assignee: Paras Negi
> Priority: Critical
> Labels: pull-request-available
>
> {code:java}
> <dependency>
> <groupId>org.apache.flink</groupId>
> <artifactId>flink-connector-jdbc</artifactId>
> <version>3.3.0-1.20</version>
> </dependency> {code}
> {code:java}
> Compilation failure
> cannot access org.apache.flink.api.connector.sink2.StatefulSink [ERROR]
> class file for org.apache.flink.api.connector.sink2.StatefulSink not found
> {code}
> Possible reason: Many existing connectors (e.g., Kafka Connector 3.x) still
> reference {{{}StatefulSink{}}}, which was present in Flink 1.x but is being
> phased out or changed in 2.x.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
