[ https://issues.apache.org/jira/browse/FLINK-7210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16116184#comment-16116184 ]
ASF GitHub Bot commented on FLINK-7210: --------------------------------------- Github user pnowojski commented on the issue: https://github.com/apache/flink/pull/4368 Thanks! :) > Add TwoPhaseCommitSinkFunction (implementing exactly-once semantic in generic > way) > ---------------------------------------------------------------------------------- > > Key: FLINK-7210 > URL: https://issues.apache.org/jira/browse/FLINK-7210 > Project: Flink > Issue Type: Improvement > Components: Streaming Connectors > Reporter: Piotr Nowojski > Assignee: Piotr Nowojski > Fix For: 1.4.0 > > > To implement exactly-once sink there is a re-occurring pattern for doing it - > two phase commit algorithm. It is used both in `BucketingSink` and in > `Pravega` sink and it will be used in `Kafka 0.11` connector. It would be > good to extract this common logic into one class, both to improve existing > implementation (for exampe `Pravega`'s sink doesn't abort interrupted > transactions) and to make it easier for the users to implement their own > custom exactly-once sinks. -- This message was sent by Atlassian JIRA (v6.4.14#64029)