You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "chris snow (JIRA)" <ji...@apache.org> on 2018/03/03 16:39:00 UTC
[jira] [Comment Edited] (FLINK-3588) Add a streaming (exactly-once)
JDBC connector
[ 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)