flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "chris snow (JIRA)" <j...@apache.org>
Subject [jira] [Comment Edited] (FLINK-3588) Add a streaming (exactly-once) JDBC connector
Date Sat, 03 Mar 2018 16:39:00 GMT

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

Mime
View raw message