You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by air23 <wa...@163.com> on 2020/10/20 07:45:53 UTC
flink cdc读取mysql,执行sql业务逻辑, sink到mysql的bug
大佬您好,mysql cdc 修改源表的数据,sink到目标表记录为空,但是再修改一次之后,目标表就有数据了。
例如:
insert into student_info
select a.id, a.name, b.name from a(id, name) left join b(id, class)
原始数据
a
id name
1 xm
b
id class
1 1班
所以
student_info 有一条数据
1, xm, 1班
此时
a表的name修改为 -> xh
student_info 的数据就变成
null, null, null
再修改a表的name -> zs
student_info 的数据就变成
1, zs, 1班