[
https://issues.apache.org/jira/browse/FLINK-3588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16384724#comment-16384724
]
chris snow edited comment on FLINK-3588 at 3/3/18 4:38 PM:
-----------------------------------------------------------
This appears to have been implemented?
{code:java}
/**
* An at-least-once Table sink for JDBC.
*
* <p>The mechanisms of Flink guarantees delivering messages at-least-once to
this sink (if
* checkpointing is enabled). However, one common use case is to run idempotent
queries
* (e.g., <code>REPLACE</code> or <code>INSERT OVERWRITE</code>) to upsert into
the database and
* achieve exactly-once semantic.</p>
*/
{code}
https://github.com/apache/flink/blob/release-1.4/flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCAppendTableSink.java
was (Author: snowch):
This appears to have been implemented?
{code:java}
/**
* An at-least-once Table sink for JDBC.
*
* <p>The mechanisms of Flink guarantees delivering messages at-least-once to
this sink (if
* checkpointing is enabled). However, one common use case is to run idempotent
queries
* (e.g., <code>REPLACE</code> or <code>INSERT OVERWRITE</code>) to upsert into
the database and
* achieve exactly-once semantic.</p>
*/
https://github.com/apache/flink/blob/release-1.4/flink-connectors/flink-jdbc/src/main/java/org/apache/flink/api/java/io/jdbc/JDBCAppendTableSink.java
{code}
> Add a streaming (exactly-once) JDBC connector
> ---------------------------------------------
>
> Key: FLINK-3588
> URL: https://issues.apache.org/jira/browse/FLINK-3588
> Project: Flink
> Issue Type: New Feature
> Components: Streaming Connectors
> Affects Versions: 1.0.0
> Reporter: Chesnay Schepler
> Priority: Major
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
