AI 助理
备案控制台
开发者社区 问答 正文

请问下要实现 在一段时间内，如果cdc没有监听到binlog数据就停止当前的flink任务，这个

请问下要实现 在一段时间内，如果cdc没有监听到binlog数据就停止当前的flink任务，这个有什么实现思路吗？

展开
收起
真的很搞笑 2023-04-19 17:30:13 112 分享 版权
来自： 阿里云实时计算Flink

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

1 条回答
写回答
取消 提交回答
  • 算精通
    北京阿里云ACE会长

    设定一个定时器，定期检查CDC是否有监听到binlog数据。可以使用Flink的定时器API，例如ProcessingTimeService或EventTimeService，在每个时间窗口内触发定时器，检查CDC是否有监听到binlog数据。

    当定时器触发时，检查CDC是否有监听到binlog数据。可以通过查询CDC的状态信息，检查最近一次更新binlog数据的时间，如果时间超过设定的阈值，则认为CDC没有监听到binlog数据。

    如果CDC没有监听到binlog数据，则调用Flink的cancel()方法停止当前的Flink任务。

    2023-07-11 07:51:38
    赞同 展开评论
问答分类：
流计算 实时计算 Flink版
问答标签：
实时计算 Flink版CDC 实时计算 Flink版数据 实时计算 Flink版任务 监听binlog binlog数据
问答地址：
开发者社区 > 阿里云实时计算Flink > 问答
相关问答
flinkcdc支持任务起动后不重启的情况下mysql source能捕获新建表的binlog吗?
87
1
0
Flink CDC中，binlog 回放的时候，是不是应该把Executed去掉?
45
0
0
Flink CDC 2.0 在新增表时为什么会停止 Binlog 日志流？
44
1
0
在Flink把源表和目标宽表都设置了binlog，为啥宽表还是没有实现实时更新呢？
45
0
0
Flink的hologres的维度表也需要开启binlog吗？
63
1
0
在Flink CDC中，请问下是没有数据，但却有binlog吗？
51
1
0
flinksql cdc连接器可以获取binlog offset 相关的元数据信息吗？
26
1
0
Flink的holo表的binlog最长生命周期是多长啊？
44
1
0
在Flink CDC中，为什么3.1复现拿不到binlog数据？
54
1
0
Flink有没有什么参数可以设置mysql作为source的 binlog的保存时长？
52
1
0