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

大佬们,Flink CDC里我设置了这两个参数,如果sink端出现问题,是不是也会重试?

大佬们,Flink CDC里我设置了这两个参数,如果sink端出现问题,是不是也会重试?restart-strategy.fixed-delay.attempts: 3
restart-startegy.fixed-delay.delay: 10s还是只针对source端?有办法针对source和sink进行设置吗
?大佬,是这样的,任务停止的主因是数据库切主会有10秒不可用状态,我想从任务日志中查看下是否有重试次数(查看重试次数有没有关键字可以搜索)

能针对source和sink也设置像restart-strategy.fixed-delay.attempts和restart-startegy.fixed-delay.delay的参数配置。

展开
收起
小小鹿鹿鹿 2024-04-22 20:37:01 26 0
2 条回答
写回答
取消 提交回答
  • 这个针对的任务级别的,不针对source还是sink。数据在flink里面是有状态的。此回答来自钉群Flink CDC 社区。

    2024-04-23 22:53:45
    赞同 1 展开评论 打赏
  • 北京阿里云ACE会长

    要查看任务日志中的重试次数,可以搜索与"RESTART"相关的日志条目,或者查找表明作业失败和随后重启的日志。Flink的日志通常会包含关于作业重启和异常的信息,包括重启的次数。

    2024-04-23 08:21:26
    赞同 展开评论 打赏

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

相关电子书

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