[
https://issues.apache.org/jira/browse/FLINK-15221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994498#comment-16994498
]
Jark Wu edited comment on FLINK-15221 at 12/12/19 10:30 AM:
------------------------------------------------------------
Hi [~chaiyq], in general, end-to-end exactly once refers exactly-once-sink
which can be implemented base on {{TwoPhaseCommitSinkFunction}}. Table API
supports exactly-once in Flink, and can also support end-to-end exactly once if
the sink is exactly-once semantic.
I'm guessing what you want is a exactly-once semantic sink, but not sure which
connector do you want. For example, Flink already supports exactly-once
{{FlinkKafkaProducer}}, but the exactly-once semantic is not exposed by
KafkaTableSink. If you want to support exactly-once Kafka sink in Table API,
you can just expose the semantic configuration for {{KafkaTableSink}}.
was (Author: jark):
Hi [~chaiyq], in general, end-to-end exactly once refers exactly-once-sink
which can implement base on {{TwoPhaseCommitSinkFunction}}. Table API supports
exactly-once in Flink, and can also support end-to-end exactly once if the sink
is exactly-once semantic.
I'm guessing what you want is a exactly-once semantic sink, but not sure which
connector do you want. For example, Flink already supports exactly-once
{{FlinkKafkaProducer}}, but the exactly-once semantic is not exposed by
KafkaTableSink. If you want to support exactly-once Kafka sink in Table API,
you can just expose the semantic configuration for {{KafkaTableSink}}.
> supporting Exactly-once for table APi
> -------------------------------------
>
> Key: FLINK-15221
> URL: https://issues.apache.org/jira/browse/FLINK-15221
> Project: Flink
> Issue Type: Wish
> Components: Table SQL / API
> Affects Versions: 1.9.0
> Reporter: chaiyongqiang
> Priority: Major
>
> The Table Api doesn't support End to End Exactly once sematic like datastream
> Api. Does Flink have a plan for this?
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
