[ 
https://issues.apache.org/jira/browse/FLINK-22141?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17324199#comment-17324199
 ] 

Maciej Bryński commented on FLINK-22141:
----------------------------------------

[~ym] 
No problem at all. 
We have this code integrated with 1.12 and want to go to production soon. So we 
did a lot of tests.

> Manually test exactly-once JDBC sink
> ------------------------------------
>
>                 Key: FLINK-22141
>                 URL: https://issues.apache.org/jira/browse/FLINK-22141
>             Project: Flink
>          Issue Type: Test
>          Components: Connectors / JDBC
>            Reporter: Roman Khachatryan
>            Assignee: Yuan Mei
>            Priority: Blocker
>              Labels: pull-request-available, release-testing
>             Fix For: 1.13.0
>
>
> In FLINK-15578, an API and its implementation were added to JDBC connector to 
> support exactly-once semantics for sinks. The implementation uses JDBC XA 
> transactions.
> The scope of this task is to make sure:
>  # The feature is well-documented
>  # The API is reasonably easy to use
>  # The implementation works as expected
>  ## normal case: database is updated on checkpointing
>  ## failure and recovery case: no duplicates inserted, no records skipped
>  ## several DBs: postgressql, mssql, oracle (mysql has a known issue: 
> FLINK-21743)
>  ## concurrent checkpoints > 1, DoP > 1
>  # Logging is meaningful



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to