[ https://issues.apache.org/jira/browse/FLINK-15578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17208377#comment-17208377 ]
Roman Khachatryan commented on FLINK-15578: ------------------------------------------- Hello [~klden], I think you can extend [GenericWriteAheadSink|https://ci.apache.org/projects/flink/flink-docs-release-1.11/api/java/index.html?org/apache/flink/streaming/runtime/operators/GenericWriteAheadSink.html]. It's currently used by Cassandra sinks. Probably [~chesnay] knows more about it. > Implement exactly-once JDBC sink > -------------------------------- > > Key: FLINK-15578 > URL: https://issues.apache.org/jira/browse/FLINK-15578 > Project: Flink > Issue Type: New Feature > Components: Connectors / JDBC > Reporter: Roman Khachatryan > Priority: Major > Labels: pull-request-available > Fix For: 1.12.0 > > Time Spent: 10m > Remaining Estimate: 0h > > As per discussion in the dev mailing list, there are two options: > # Write-ahead log > # Two-phase commit (XA) > the latter being preferable. > -- This message was sent by Atlassian Jira (v8.3.4#803005)