[
https://issues.apache.org/jira/browse/FLINK-37987?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17985858#comment-17985858
]
Poorvank Bhatia commented on FLINK-37987:
-----------------------------------------
Hey [~Leonard] , Can u have a look and assign this to me?
> Implement JdbcDynamicTableSinkV2 (JDBC Sink) to use new Sink API v2
> -------------------------------------------------------------------
>
> Key: FLINK-37987
> URL: https://issues.apache.org/jira/browse/FLINK-37987
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / JDBC
> Reporter: Poorvank Bhatia
> Priority: Major
>
> While [FLINK-25421|https://issues.apache.org/jira/browse/FLINK-25421]
> implemented the new JdbcSink using Sink API v2, the Table API integration
> ([JdbcDynamicTableSink|https://github.com/apache/flink-connector-jdbc/blob/main/flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/core/table/sink/JdbcDynamicTableSink.java])
> still uses the legacy
> [GenericJdbcSinkFunction|https://github.com/apache/flink-connector-jdbc/blob/main/flink-connector-jdbc-core/src/main/java/org/apache/flink/connector/jdbc/internal/GenericJdbcSinkFunction.java]
> path.
> Need to create JdbcDynamicTableSinkV2 that leverages the existing JdbcSink
> implementation instead of the legacy GenericJdbcSinkFunction.
> As mentioned in
> [FLIP-239|https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=217386271#FLIP239:PortJDBCConnectortoFLIP27&FLIP143-TableSink]
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
