flink cdc读取mysql,执行sql业务逻辑, sink到mysql的bug

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

flink cdc读取mysql,执行sql业务逻辑, sink到mysql的bug

air23
大佬您好,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班