问题一:Flink CDC 里这是什么问题?
Flink CDC 里这是什么问题?
参考回答:
检查表名和模式:确认 LOG_MINING_FLUSH 表确实存在于数据库中,并且表名没有拼写错误。如果您的数据库使用模式(schema),也要确保模式名正确。
检查用户权限:确保执行 Flink CDC 作业的用户具有足够的权限来访问和更新 LOG_MINING_FLUSH 表。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/605879
问题二:Flink CDC 里我这边本地跑代码没有问题,但是在flink上执行sql命令,错误怎么办?
Flink CDC 里我这边本地跑代码没有问题,但是在flink上执行sql命令,错误怎么办?
参考回答:
你本地也用cdc2.4么,是不是两边包不一致。这个问题可以查一下依赖的包,有可能同一个类下,一个类是用的 shaded 后的包路径,另一个是用的 没有shaded 的包路径导致的。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/605878
问题三:Flink CDC 里这个是因为什么原因?
Flink CDC 里这个是因为什么原因?
参考回答:
那就是链接失效问题。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/605876
问题四:Flink CDC 里这个怎么做?
Flink CDC 里这个怎么做?
参考回答:
换2.3.0以上版本,注意带宽,以及主备切换问题。或者注意是不是人为删除binlog,或者下游消费速度太慢,优化一下下游库。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/605873
问题五:Flink cdc同步postgresql的分区表支持?
Flink cdc同步postgresql的分区表支持?
参考回答:
分区表可以同步,把所有的分区子表添加到tableList,或者用正则。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/605863