Flink CDC 中JM里面能看到这个日志么,这里表明reader汇报 自己接收到了binlog?
Flink CDC 的 reader 会定期向 JM 发送心跳,以表明自己仍然正常工作。你可以在 JM 的 logs 目录中找到这些心跳日志。
以下是 Flink CDC 的 reader 的心跳日志示例:
2022-04-21 14:09:34,606 INFO [main] com.ververica.cdc.connectors.mysql.MySqlSourceReader - [SOURCE_ID: my-cdc-connector-0] [TABLE_ID: dm_user] [PARTITION_ID: 0] Received MySQL binlog event with position [LogPosition: BinlogPosition(853, 1)]
其中:
SOURCE_ID 是 Flink CDC 的源 ID。
TABLE_ID 是 Flink CDC 的表 ID。
PARTITION_ID 是 Flink CDC 的分区 ID。
LogPosition 是 MySQL 的 binlog 位置。
你可以根据这些信息,来判断 Flink CDC 的 reader 是否正常工作。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。