: Re: 基于flink 1.12 如何通过Flink SQL 实现 多sink端 在同一个事务中
对于Exactly-Once模式下的checkpoint，如果sink端支持两段式事务，应该就可以做到一个sink失败，整个checkpoint失败的。
不过JDBC sink支持Exactly-Once是1.13.0以后的事情了，建议检查一下你的版本和配置
在 2021-08-30 16:27:24，"wukon...@foxmail.com" 写道：
>Hi:
> 我理解这种方式， 目前我只是想让先
一逻辑
>
>
>
>wukon...@foxmail.com
>
>发件人： Shuo Cheng
>发送时间： 2021-08-30 10:19
>收件人： user-zh
>主题： Re: 基于flink 1.12 如何通过Flink SQL 实现 多sink端 在同一个事务中
>你好, 你说的这种控制写入的方式在同一个 Flink SQL job 里是无法实现的. 控制数据是否写入某个
>Sink，可以看看是否从逻辑上能在 Sink 前加一个 Filter，从而达到过滤目的；如果 kafka sink 跟 MySQL
>表是
Hi:
我理解这种方式， 目前我只是想让先插入数据到Mysql 然后再通过通知到下游，来查询Mysql 进行数据etl 不知道大家如何通过SQL来实现这一逻辑
wukon...@foxmail.com
发件人： Shuo Cheng
发送时间： 2021-08-30 10:19
收件人： user-zh
主题： Re: 基于flink 1.12 如何通过Flink SQL 实现 多sink端 在同一个事务中
你好, 你说的这种控制写入的方式在同一个 Flink SQL job 里是无法实现的. 控制数据是否写入某个
Sink，可以看看是否从逻辑上能在 Sink 前加一个
能具体说下如何实现吗？ 我用cdc 能实现什么，我现在想让两个Insert Sql 保持到一个事务里， 要么全成功，要么全失败，目前查看Flink 文档
并没有发现相关的解释
wukon...@foxmail.com
发件人： jie han
发送时间： 2021-08-26 21:36
收件人： user-zh
主题： Re: 基于flink 1.12 如何通过Flink SQL 实现 多sink端 在同一个事务中
HI：
可以尝试下使用flink cdc 的方式写入到第二个kafka里面呀
悟空 于2021年8月26日周四 下午1:54写道：
> 我目前
"user-zh"
>> <
>> tsreape...@gmail.com>;
>> 发送时间: 2021年8月26日(星期四) 中午1:25
>> 收件人: "user-zh">
>> 主题: Re: 基于flink 1.12 如何通过Flink SQL 实现 多sink端 在同一个事务中
>>
>>
>
"user-zh"
> <
> tsreape...@gmail.com>;
> 发送时间: 2021年8月26日(星期四) 中午1:25
> 收件人: "user-zh"
> 主题: Re: 基于flink 1.12 如何通过Flink SQL 实现 多sink端 在同一个事务中
>
>
>
> Hi！
>
> 如果 statement set 已经包含了多个 in
"user-zh"
> <
> fskm...@gmail.com>;
> 发送时间: 2021年8月26日(星期四) 中午12:36
> 收件人: "user-zh"
> 主题: Re: 基于flink 1.12 如何通过Flink SQL 实现 多sink端 在同一个事务中
>
>
>
> 说的是 statement set [1] 吗 ？
>
> [1]
>
> https://ci.apache.or
说的是 statement set [1] 吗 ？
[1]
https://ci.apache.org/projects/flink/flink-docs-master/docs/dev/table/sqlclient/#execute-a-set-of-sql-statements
悟空 于2021年8月26日周四 上午11:33写道：
> hi all:
> 我目前基于flink 1.12 sql 来开发功能， 目前遇到一个问题， 我现在想实现 在一个事务里 先将kafka
> 源的数据写入到一张msyql 表中， 写入成功后再写入一张kafka的表里。如果写入db失败
