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

  1. 云栖社区>
  2. 博客>
  3. 正文

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

Ververica 2019-07-18 21:11:30 浏览838
展开阅读全文

作者 | Fabian Hueske & Andrey Zagrebin
翻译 | 唐云

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

在本文中,我们将讨论引入状态生存时间特性的动机并讨论其相关用例。此外,我们还将演示如何使用和配置该特性。同时,我们将会解释Flink如何借用状态生存时间特性在内部管理状态,并对Flink 1.8.0中该功能引入的相关新特性进行一些展示。本文章最后对未来的改进和扩展作了展望。

状态的暂时性

有两个主要原因可以解释为什么状

网友评论

登录后评论
0/500
评论
Ververica
+ 关注