知识卡片

流SQL受状态约束

专业/工作 · 503.g.1

内容

无界流上的查询如果需要长期记住历史数据,就必须考虑状态规模和可清理条件。发散:SQL 写得像批处理,不代表运行成本也像批处理。

参考来源

- 位置:《Flink原理与实践》第8章《Table API & SQL的介绍和使用》(源文件:_epub-src/OEBPS/Text/chapter11.xhtml) - 结论依据:原文围绕“流处理的限制”给出定义、流程、对比或限制条件,本卡片据此提炼其可迁移的框架机制,并补充了使用边界或工程启发。 - 原始内容:的TableSink紧密结合,比如Key-Value数据库更适合进行Upsert操作。 8.2.2 流处理的限制 至此,我们已经了解了流式关系型查询的基本原理,但目前Flink的流处理并不能支持所有的SQL语句,因为流处理的本质是使用状态来缓存数据,包括表和中间计算过程都是Flink中的状态。因此,……