mysqlcdc 多表join

[skywalker2256]

cdc文档中可以直接两张mysqlcdc表left join；但是我测试的时候怎么发现少数据

当我测试sql
select t1.id,t1.user_id,t2.user_name,t1.nums
from default_catalog.default_database.qi_nums t1 left join default_catalog.default_database.qi_user t2
on t1.user_id =t2.user_id ;
如下图中更新userid=6的数据，只有一条数据的username被更新,这是需要flink在其他额外配置吗？

[skywalker2256]

表主键设置问题