开发者社区> 问答> 正文
1
0
分享

Apache Flink 中节点不持久化低水印有何影响?

Apache Flink 中节点不持久化低水印有何影响?

展开
收起
真的很搞笑 2024-06-17 20:20:10 39 0 发布于黑龙江
举报
飞天免费试用计划
领取免费云资源,开启云上实践第一步
实时计算 Flink 版
5000CU*H 3个月
额度3个月内有效
1 条回答
写回答
取消 提交回答
  • 在 Apache Flink 中,由于节点不持久化低水印,当节点发生故障时,整个 Pipeline 必须从上一个检查点开始恢复,故障节点的低水位线将设置为低值常量,直到节点在其所有输入边上收到新的低水印消息后才会被重新设置。这种设计带来的优势是 Flink 端到端的数据处理延迟较低,但缺点是故障恢复(FO)的时间比使用持久化低水印的引擎(如 MillWheel/Cloud DataFlow)长。

    2024-06-17 20:42:26 举报
    赞同 1 评论 打赏

    评论

    全部评论 (0)

    登录后可评论
问答排行榜
最热
最新

相关电子书

更多
Apache Flink技术进阶 立即下载
Apache Spark: Cloud and On-Prem 立即下载
Hybrid Cloud and Apache Spark 立即下载

相关镜像

AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等