问题一:Flink CDC 里在idea里面跑没问题,放到flink里面run报上面这个错误是什么问题?
Flink CDC 里在idea里面跑没问题,放到flink里面run报上面这个错误是什么问题?
参考回答:
缺少oracle驱动。代码中添加Class.Forname('xxxxx')。主动添加驱动。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/602725
问题二:Flink CDC 里flink1.18滚动窗口不打印是什么情况?
Flink CDC 里flink1.18滚动窗口不打印是什么情况?
参考回答:
可以检查一下watermark的设置是否合理,或者数据时间是否远远大于watermark和窗口时间,导致窗口数据经常为空。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/602723
问题三:Flink CDC 里flink是docker部署的,目前想把postgre同步到es,报错咋办?
Flink CDC 里flink是docker部署的,目前想把postgre同步到es,报错咋办?
参考回答:
默认就是child-first,你得加一个配置,classloader.resolve-order: parent-first 。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/602716
问题四:麻烦问一下Flinkwatermark信息丢失了。怎么办?
麻烦问一下Flinkwatermark信息丢失了。怎么办?
参考回答:
bid表rowtime字段选错了,没选原表中定义watermark那个字段 ,
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/602593
问题五:flink-connector-tidb-cdc demo例子一直获取不到事件
flink-connector-tidb-cdc demo例子一直获取不到事件
参考回答:
在使用Flink CDC TiDB Connector时,如果无法获取到事件,可能是由于以下原因之一:
- 网络连接问题:确保您的Flink集群和TiDB数据库之间的网络连接正常。检查防火墙设置、网络配置等,确保它们允许Flink与TiDB进行通信。
- 权限问题:确保Flink集群具有足够的权限来访问TiDB数据库。检查Flink集群的用户名、密码以及所需的权限是否正确配置。
- 表结构变化:如果您在TiDB中对表进行了结构更改(例如添加或删除列),可能会导致CDC无法正确读取事件。请确保表结构没有发生变化,或者您已经处理了这些变化。
- 数据类型不匹配:某些数据类型可能无法正确地映射到Flink的数据类型。请确保您的表结构和数据类型与Flink CDC的要求相匹配。
- 版本兼容性问题:确保您使用的Flink CDC TiDB Connector版本与您的Flink集群版本兼容。不同版本的Connector可能需要不同的配置或依赖项。
如果您仍然无法解决问题,建议查看Flink和TiDB的日志文件以获取更多详细信息。您可以在Flink和TiDB的配置文件中启用详细的日志记录,以便更好地了解问题所在。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/602426