开发者社区> 问答> 正文

Flink希望开发者怎么处理程序的异常?

Hi, 各位大佬们,请教几个问题:     背景:Flink程序在正常运行过程中由于某些原因抛出异常了(比如数据不正确、NullPointer等),设置了checkpoint,程序默认会无限重启,都没办法savepoint。     问题1:  Flink希望开发者怎么处理程序的异常?     问题2:checkpoint是否可以转化为savepoint,使得在没来得及savepoint之前能够进行恢复?     问题3:如果我某条数据导致了异常,怎么样才忽略这条数据而不影响应用的状态和运行?

*来自志愿者整理的flink邮件归档

展开
收起
游客nnqbtnagn7h6s 2021-12-06 20:05:35 747 0
1 条回答
写回答
取消 提交回答
  • 1.生产环境中一般都需要try catch捕获异常,因为无法保证上游数据完全没有问题 2.程序默认无限重启代表你的数据有问题,重复处理错误数据,重复失败重启,根本原因还是在错误数据这里 3.某条数据出现异常,try catch + 加perf log + 加监控(报警)等

    *来自志愿者整理的flink邮件归档

    2021-12-06 21:39:05
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载