[ 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)