实时计算 Flink版产品使用合集之flinksql多流join，left右边任意一张表数据到后，是否都会更新test中对应的数

问题一：Flink CDC我这里多出来的10G是怎么回事？

Flink CDC我这里多出来的10G是怎么回事？

参考回答：

看看并行度

关于本问题的更多回答可点击原文查看：https://developer.aliyun.com/ask/572309

问题二：请问这种flinksql多流join，left右边任意一张表数据到后，是否都会更新test中对应的数

insert into test

select

en.contentId,

fa.name,

fa.inpoint,

cs.out

from kafka_ods_source1 cs

left join kafka_ods_source2 fa on fa.cid=cs.cid and fa.In=cs.in and fa.Out=cs.out

left join kafka_ods_source3 en on en.cid=cs.cid

请问这种flinksql多流join，left右边任意一张表数据到后，是否都会更新test中对应的数据呢?目前发现kafka_ods_source3表数据到后，test中对应字段好像没自动更新

参考回答：

多流join都会触发计算

关于本问题的更多回答可点击原文查看：https://developer.aliyun.com/ask/572307

问题三：Flink CDC如果库里面存在无主键表的话就直接把作业kill掉了?

Flink CDC监控的表配置的是database.* ，如果库里面存在无主键表的话就直接把作业kill掉了?flink cdc没法做到忽略异常，不杀死作业吗？

参考回答：

你自己判断不出来的话，无法屏蔽无主键表

关于本问题的更多回答可点击原文查看：https://developer.aliyun.com/ask/572303

问题四：Flink CDC读取sqlserver的update，这个要怎么解决？

Flink CDC读取sqlserver的update，输出到kafka的消息op标志只有c，这个要怎么解决？困扰了比较久，读取mysql会是两条消息，一条d，一条c

参考回答：

这个问题可能是由于Flink CDC在处理MySQL的UPDATE操作时，没有正确识别到变更数据。为了解决这个问题，你可以尝试以下方法：

1. 确保你的MySQL表有一个唯一的主键或者唯一索引，这样Flink CDC才能准确地识别出哪些行发生了变更。
   
2. 检查你的MySQL表是否有触发器或者其他外部操作，这些操作可能会影响Flink CDC的读取结果。如果有，请确保这些操作不会影响数据的一致性。
   
3. 尝试使用不同的Flink CDC版本，看看是否能解决问题。有时候，不同版本的Flink CDC可能存在一些已知的问题。
   
4. 如果以上方法都无法解决问题，你可以考虑使用其他工具（如Debezium）来替代Flink CDC，因为Debezium对MySQL的支持可能更好。

关于本问题的更多回答可点击原文查看：https://developer.aliyun.com/ask/572301