1.1.2.1 批作为流的特例

文档摘要

1.1.2.1 批作为流的特例 1.1.2.1 批作为流的特例：当Flink的在Checkpoint失败时，如何用绕过状态快照陷阱？——一个被忽略的、却每天在生产环境里悄悄吞掉SLA的底层机制凌晨两点十七分，告警钉钉弹窗第7次震动。不是CPU爆了，不是OOM了，也不是Kafka lag飙升——是那个本该在00:05准时完成的“日终报表任务”，卡死在里，状态大小从23MB一路涨到1.8GB，最终触发，整个作业被强制cancel。运维同事甩来一句：“又来了，批任务跑着跑着变流了，你看看是不是Flink又把批当流跑了？” 这不是玄学。这是Flink 1.