开发者社区 问答 正文

如果在exactly-once 的checkpoint模式下,处理数据出现异常该怎么处理因为重启会一直在那个点重跑 岂不是一直fail

转自钉钉群21789141:
如果在exactly-once 的checkpoint模式下,处理数据出现异常该怎么处理因为重启会一直在那个点重跑
岂不是一直fail
个人觉得flink代码的成熟性还是蛮差的,相对于spark,很多逻辑都是因为源码没有做异常处理导致

展开
收起
赵慧@ApacheFlink中文社区 2018-10-18 14:55:56 3314 分享 版权
1 条回答
写回答
取消 提交回答
  • 徐前进:这种貌似只能增加代码的容错 如果不重试 跳过就会导致数据丢失

    2019-07-17 23:09:16
    赞同 展开评论