Re: 基于flink 1.12 如何通过Flink SQL 实现 多sink端 在同一个事务中

[Shengkai Fang]

说的是 statement set [1] 吗 ？

[1]
https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/table/sqlclient/#execute-a-set-of-sql-statements

悟空 <wukon...@foxmail.com> 于2021年8月26日周四 上午11:33写道：

> hi all:&nbsp;
> &nbsp; &nbsp; 我目前基于flink 1.12 sql 来开发功能， 目前遇到一个问题， 我现在想实现 在一个事务里 先将kafka
> 源的数据写入到一张msyql 表中， 写入成功后再写入一张kafka的表里。如果写入db失败，则不写入kafka 。
> &nbsp; &nbsp;语句类似这种：
> &nbsp; &nbsp;insert into db_table_sink&nbsp;select * from&nbsp;
> kafka_source_table;
> &nbsp; &nbsp;insert into kafka_table_sink select * from kafka_source_table;
>
>
> &nbsp; 请问flink SQL 有实现方式吗？ 目前经过测试，发现如果db写入失败，但是kafka依旧写入，同时flink 程序没有挂掉。