译:Flink ---状态和容错

2019-02-13  本文已影响0人  雪味伦调

Flink 1.7 Google翻译

有状态函数和运算符在各个元素/事件的处理中存储数据,使状态成为任何类型的更精细操作的关键构建块
例如:

Flink需要了解状态,以便使用检查点使状态容错,并允许流应用程序的保存点。

有关状态的知识还允许重新调整Flink应用程序,这意味着Flink负责跨并行实例重新分配状态。

Flink的可查询状态功能允许您在运行时从Flink外部访问状态

在使用state时,阅读Flink的状态后端可能也很有用。 Flink提供了不同的状态后端,用于指定状态的存储
式和位置。 State可以位于Java的堆上或堆外。根据您的状态后端,Flink还可以管理应用程序的状态,这
意味着Flink处理内存管理(如果需要可能会溢出到磁盘)以允许应用程序保持非常大的状态。可以在不更改
应用程序逻辑的情况下配置状态后端

上一篇下一篇

猜你喜欢

热点阅读