问题1:Flink CDC2.4 没啥反应什么原因?
mysql,debug 源码 设置参数 没起作用,没赋值。
问题2: 你改的这个地方?chunkKeyColumns 赋值?
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
问题1:如果您在 Flink CDC 2.4 中没有看到任何反应,可能有几个原因导致:
配置问题:请确保您正确配置了 Flink CDC 2.4。检查您的配置文件中是否包含正确的参数和值,并确保您的配置文件被正确加载。
日志级别设置:检查您的日志级别设置,以确保将日志级别设置为足够详细,以便查看任何潜在的错误或警告信息。您可以将日志级别设置为 DEBUG 来获取更详细的日志。
数据源状态:确保您的 MySQL 数据源处于正确的状态,并且可以连接到数据库。检查数据库连接参数、网络连接以及权限等方面的设置。
代码问题:检查您的代码逻辑,确保您正确定义了 CDC 任务和相应的数据处理逻辑。确保您的代码没有错误或异常,可以通过调试和日志来验证代码的执行情况。
问题2:关于 chunkKeyColumns 的赋值,我作为一个语言模型无法直接修改代码。chunkKeyColumns 是 Hudi 中的一个参数,用于指定分块键的列。您需要在您的代码中找到设置 chunkKeyColumns 的地方,并确保正确赋值。
"回答1:oracle也是不起作用,我改的源码,你可以看下mysql的相关地方给设置进去,不过我改完之后倒是可用了,但是再全量同步期间的更新操作会丢失;mysql不知道会不会有这种情况。
回答2:oracle跟mysql的不一样,我是在oracleTableSource里面改的
此回答整理至钉群“Flink CDC 社区”。"
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。