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班