State Processor API:如何读取,写入和修改 Flink 应用程序的状态

State Processor API:如何读取,写入和修改 Flink 应用程序的状态

过去无论是在生产中使用,还是调研 Apache Flink,总会遇到一个问题:如何访问和更新 Flink 保存点(savepoint)中保存的 state?Apache Flink 1.9 引入了状态处理器(State Processor)API,它是基于 DataSet API 的强大扩展,允许读取,写入和修改 Flink 的保存点和检查点(checkpoint)中的状态。

Apache Flink 1.8.0 中的状态生存时间特性:如何自动清理应用程序的状态

Apache Flink 1.8.0 中的状态生存时间特性:如何自动清理应用程序的状态

对于许多状态流式计算程序来说,一个常见的需求是自动清理应用程序的状态(state),以便有效地控制状态大小,或者控制程序访问状态的有效时间(例如受限于诸如GDPR等法律条规)。Apache Flink 自 1.6.0 版本引入了状态的生存时间(time-to-live,TTL)功能,使得应用程序的状态清理和有效的状态大小管理成为可能。

浙公网安备 33010802010061号 浙ICP备19028187号