Flink-跟着问题读源码:CheckPoint超时问题总结

最近一段时间处理的业务数据量的增长和处理流程的复杂性,导致flink实时作业不仅仅局限于结果正确,更多的精力放在了性能优化上,接下来对近期CheckPoint时长优化进行总结。 我们都知道checkpoint的重要性,整体过程如下: JobManager 向 Source 算子发送 Barrier ,初始化 Checkpoint,即JM向Source发起Trigger操作; 各个Source 算子
相关文章
相关标签/搜索