[
https://issues.apache.org/jira/browse/FLINK-39426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18085378#comment-18085378
]
Paras Negi commented on FLINK-39426:
------------------------------------
{quote}this ticket is about releasing a flink-connector-jdbc version that is
compatible with Flink 2.0+
{quote}
I believe that release already happened — JDBC 4.0.0-2.0 (Flink 2.x) , it just
ships as [per-database
modules|https://central.sonatype.com/artifact/org.apache.flink/flink-connector-jdbc-mysql/versions]
now.
The dependency in this report is {{flink-connector-jdbc:3.3.0-1.20}} — the
*Flink 1.x* line. That exact coordinate has no 2.x build because the deprecated
{{flink-connector-jdbc}} umbrella module was removed in 4.0
([891c0e9|https://github.com/apache/flink-connector-jdbc/commit/891c0e9cd373]
"Remove deprecated flink-connector-jdbc module", FLINK-36659); the 2.x
connector now ships as per-db modules, e.g.
[flink-connector-jdbc-mysql:4.0.0-2.0|https://central.sonatype.com/artifact/org.apache.flink/flink-connector-jdbc-mysql/4.0.0-2.0].
The same holds ecosystem-wide — every connector using these interfaces is
covered:
* *Released for 2.x:* Kafka, Elasticsearch, AWS, JDBC
* *Release pending:* OpenSearch, MongoDB
* *In progress:* Pulsar
> 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)
