Poorvank Bhatia created FLINK-37987:
---------------------------------------
Summary: Implement JdbcDynamicTableSinkV2 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
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)
