TwoPhaseCommitSinkFunction在TableAPI &SQL中的应用

[lec ssmi]

Hi:
   将TwoPhaseCommitSinkFunction 在TableAPI中的Sink实现，能够生效吗？看案例都是DataStream
API在使用。
 谢谢。

[Jingsong Li]

能生效
Table中就是使用FlinkKafkaProducer的，它就是一个TwoPhaseCommitSinkFunction

Best,
Jingsong Lee

On Mon, Apr 27, 2020 at 10:50 AM lec ssmi <[hidden email]> wrote:

> Hi:
>    将TwoPhaseCommitSinkFunction 在TableAPI中的Sink实现，能够生效吗？看案例都是DataStream
> API在使用。
>  谢谢。
>


--
Best, Jingsong Lee