开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink CDC2.4 没啥反应什么原因?

问题1:Flink CDC2.4 没啥反应什么原因?
690429013ff210a28cd0c075a9635db0.png
mysql,debug 源码 设置参数 没起作用,没赋值。
问题2: 你改的这个地方?chunkKeyColumns 赋值?
9750562b313b159947055d0808b84e8f.png

展开
收起
十一0204 2023-08-09 09:46:25 58 0
2 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    问题1:如果您在 Flink CDC 2.4 中没有看到任何反应,可能有几个原因导致:

    配置问题:请确保您正确配置了 Flink CDC 2.4。检查您的配置文件中是否包含正确的参数和值,并确保您的配置文件被正确加载。

    日志级别设置:检查您的日志级别设置,以确保将日志级别设置为足够详细,以便查看任何潜在的错误或警告信息。您可以将日志级别设置为 DEBUG 来获取更详细的日志。

    数据源状态:确保您的 MySQL 数据源处于正确的状态,并且可以连接到数据库。检查数据库连接参数、网络连接以及权限等方面的设置。

    代码问题:检查您的代码逻辑,确保您正确定义了 CDC 任务和相应的数据处理逻辑。确保您的代码没有错误或异常,可以通过调试和日志来验证代码的执行情况。

    问题2:关于 chunkKeyColumns 的赋值,我作为一个语言模型无法直接修改代码。chunkKeyColumns 是 Hudi 中的一个参数,用于指定分块键的列。您需要在您的代码中找到设置 chunkKeyColumns 的地方,并确保正确赋值。

    2023-08-11 17:20:46
    赞同 展开评论 打赏
  • 意中人就是我呀!

    "回答1:oracle也是不起作用,我改的源码,你可以看下mysql的相关地方给设置进去,不过我改完之后倒是可用了,但是再全量同步期间的更新操作会丢失;mysql不知道会不会有这种情况。
    回答2:oracle跟mysql的不一样,我是在oracleTableSource里面改的
    174fb34003e548e4e98d145c9a1ea0af.png
    此回答整理至钉群“Flink CDC 社区”。"

    2023-08-09 12:12:33
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 覃立辉 立即下载
    Flink CDC Meetup PPT - 孙家宝 立即下载
    Flink CDC Meetup PPT - 徐榜江 立即下载