问题一:如果编译方式对的话,使用jdk17也是可以用flinkcdc的?
如果编译方式对的话,使用jdk17也是可以用flinkcdc的?jdk8的时候flinkcdc编译不报错
参考回答:
是的,Apache Flink的官方文档明确指出,Flink CDC支持JDK 8、JDK 11和JDK 17。所以,只要你的编译方式正确,你可以使用任何这些版本的JDK来运行Flink CDC。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/571770
问题二:mysql通过flink cdc同步数据,有没有办法所有表共用一个dump线程?
mysql通过flink cdc同步数据,我看到一个表就是生成slave dump,有没有办法所有表共用一个dump线程,否则太多表造成binlog重复读取?
参考回答:
1、参考开源的整库同步
2、参考云厂商的cdas
3、使用ds配合动态加表实现
4、等flink-cdc 3.0的整库同步,目前大佬在开发中
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/571769
问题三:flink cdc是jdk1.8可以编译成功jdk17一直编译不成功,是不是就算自己编译也不行还是?
flink cdc是jdk1.8可以编译成功jdk17一直编译不成功,是不是就算自己编译也不行还是?
一直报这个错?
参考回答:
编译包是在对应连接器的sql包里面进行编译
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/571768
问题四:Flink CDC一直是这样怎么办?
Flink CDC一直是这样怎么办?
参考回答:
如果您遇到Flink CDC卡住不动的情况,可以考虑以下几个方面:
- 资源问题: 确保任务所需的资源足够充足,包括CPU、内存和磁盘空间等。
- 网络问题: 检查网络连接情况和带宽限制。
- 系统状态: 检查目标端和源端系统的状态。
- 日志文件: 检查日志文件中的错误和警告信息。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/571767
问题五:Flink CDC换了一台数据库检查点就疯狂失败,在执行检查点的时候与数据库有关系没得?
Flink CDC换了一台数据库检查点就疯狂失败,前面几次还是好的,后面就失败了,pg cdc 同步,flink 在执行检查点的时候与数据库有关系没得?
参考回答:
是的,Flink CDC在执行检查点时确实会与数据库进行交互。这是因为检查点需要记录当前处理的数据库事务的位置,以便在任务失败时能够从该位置恢复。
如果你在更换数据库后检查点开始失败,可能是因为新的数据库环境导致了问题。例如,可能是网络连接问题,或者是数据库的并发限制影响了检查点的执行。
你可以先检查一下日志,看看检查点失败的原因是什么。如果是网络连接问题,你可能需要调整连接参数。如果是数据库的并发限制,你可能需要联系数据库管理员增加限制。
另外,你也可以尝试在Flink的任务配置中增加检查点的间隔,以减少检查点的频率,从而降低因检查点执行导致的故障风险。但是请注意,这可能会增加数据丢失的风险,因为间隔增加后,如果在两次检查点之间任务失败,可能会导致更多的数据丢失。
关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/571766