Flink 状态与容错 ( state 和 Fault Tolerance)

Flink 状态与容错 状态性的函数和操做经过处理单个(元素/事件)存储数据，使任何类型的state构建更复杂的操做。html 例如：java 当应用程序针对特定事件模式进行搜索的时候，state将会存储到目前为止的一些列事件。 当每 分钟/小时/天 聚合事件的时候，state会持有全部等待聚合的数据。 当在一连串的数据流上训练机器学习模型时，state持有当前版本的模型参数。 当历史数据须要管理

>>阅读原文<<