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

Flink CDC 中JM里面能看到这个日志么,这里表明reader汇报 自己接收到了binlog?

Flink CDC 中JM里面能看到这个日志么,这里表明reader汇报 自己接收到了binlog?image.png

展开
收起
真的很搞笑 2023-08-23 16:57:18 56 0
1 条回答
写回答
取消 提交回答
  • 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 是否正常工作。

    2023-09-18 17:01:26
    赞同 展开评论 打赏

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

相关产品

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

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    PolarDB-X 2.0 全局 Binlog 与备份恢复能 立即下载