能生效 Table中就是使用FlinkKafkaProducer的，它就是一个TwoPhaseCommitSinkFunction
Best, Jingsong Lee On Mon, Apr 27, 2020 at 10:50 AM lec ssmi <[email protected]> wrote: > Hi: > 将TwoPhaseCommitSinkFunction 在TableAPI中的Sink实现，能够生效吗？看案例都是DataStream > API在使用。 > 谢谢。 > -- Best, Jingsong Lee
