今天阳光很暖
09
12
Flink系列 14. 介绍Flink中的StateBackend Flink系列 14. 介绍Flink中的StateBackend
1. 状态后端介绍 Flink 实时计算数据场景下,有时需要启动 checkpoint 保存数据的状态,那么状态会随着 checkpoint 被持久化某个地方,以防止数据丢失,保证状态数据能够在需要恢复程序状态时保持数据的一致性。而进行 c
2020-09-12
06
Flink系列 13. 介绍Flink中的Operator State 和 Keyed State Flink系列 13. 介绍Flink中的Operator State 和 Keyed State
1. Flink State 介绍1.1 什么是 State(状态) 由一个任务维护,并且用来计算某个结果的所有数据,就属于这个任务的状态 可以认为状态就是一个本地变量,可以被任务的业务逻辑访问 当任务失败时,可以使用状态恢复数据 状态始终
2020-09-06