浅谈Flink的checkPoint机制

2020-09-11flink12 分钟读完 (大约 1872 个字)

为了保证state的容错性，Flink需要对state进程checkPoint,Checkpoint是Flink实现容错机制最核心的功能。

浅谈flink state状态管理机制

2020-09-09flink15 分钟读完 (大约 2292 个字)

Apache Flink®—Stateful Computations over Data Streams,flink是一个默认就有状态的分分析引擎，针对流失计算引擎中的数据往往是转瞬即逝，但在flink真实业务场景确不能这样，什么都不能留下，肯定是需要有数据留下的，针对这些数据留下来存储下来，在flink中叫做state，中文可以翻译成状态。