知识卡片

状态TTL防无限膨胀

专业/工作 · 503.g.1.a

内容

状态过期时间为持续查询设置清理边界,避免 Join、子查询等算子因无限历史而撑爆状态。发散:流 SQL 的 WHERE 条件不只是语义,也是在帮状态找出口。

参考来源

- 位置:《Flink原理与实践》第8章《Table API & SQL的介绍和使用》(源文件:_epub-src/OEBPS/Text/chapter11.xhtml) - 结论依据:原文围绕“状态过期时间”给出定义、流程、对比或限制条件,本卡片据此提炼其可迁移的框架机制,并补充了使用边界或工程启发。 - 原始内容:行一次排序,这对流处理框架的性能要求极高。目前,Flink在这方面的功能正在不断完善。 8.2.3 状态过期时间 通过前面的讨论,我们看到Flink通过状态来保存一些中间数据。但是状态不能无限增加,否则会突破存储限制。Flink提供了一个配置,帮助我们清除一些空闲状态数据。 tEnv.getConf……