flink 1.16.0没捕获到源mysql表数据的变化，请问又可能是什么原因呢？

flink 1.16.0没捕获到源mysql表数据的变化，请问又可能是什么原因呢?源库的binlog是开启了的图片.png

收起

wenti 2023-02-06 16:15:34 203 发布于云南版权

2 条回答

写回答

取消提交回答

哈哈是我
1. 检查 Flink 是否正确配置了 MySQL CDC 连接器。
  检查 MySQL binlog 是否正确配置。
  检查 MySQL binlog 是否正确写入。
  检查 Flink 是否正确读取 MySQL binlog。
  检查 Flink 是否正确处理 MySQL binlog 中的数据。
2024-02-27 18:27:41 举报

赞同评论

评论
全部评论 (0)
登录后可评论
认真学习的heart

是的，阿里云flink 1.16.0没捕获到源mysql表数据的变化，可能是源库的binlog没有开启，或者没有正确配置。

2023-02-06 19:15:19 举报

赞同评论

评论
全部评论 (0)
登录后可评论

问答分类：

关系型数据库 MySQL 流计算云数据库 RDS MySQL 版实时计算 Flink版

问答标签：

实时计算 Flink版mysql flink云数据库 RDS MySQL 版实时计算 Flink版表数据云数据库 RDS MySQL 版捕获实时计算 Flink版捕获

问答地址：

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

实时计算 Flink

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

我要提问

收录在圈子:

阿里云实时计算Flink

199212

+ 订阅

实时计算 Flink 版（Alibaba Cloud Realtime Compute for Apache Flink，Powered by Ververica）是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统，由 Apache Flink 创始团队官方出品，拥有全球统一商业化品牌，完全兼容开源 Flink API，提供丰富的企业级增值功能。

Flink CDC 3.4 发布, 优化高频 DDL 处理，支持 Batch 模式，新增 Iceberg 支持

阿里云《快速连接云数据库RDS》训练营，火热开营中！

客户说｜保险极客引入阿里云AnalyticDB，多业务场景效率大幅提升

【免费动手教程上线】阿里云RDS MySQL推出大容量高性能存储：高性能本地盘（最高16TB存储空间）、高性能云盘（最高64TB存储空间）

【赵渝强老师】Scala编程语言