CheckPoint 当程序出现问题需要恢复 Sate 数据的时候，只有程序提供支持才可以实现 State 的容错。State 的容错需要依靠 CheckPoint 机制，这样才可以保证 Exactly-once 这种语义，但是注意，它只能保证 Flink 系统内的 Exactly-once ...

（一）.SessionStorage 会话储存 （二）.localStorage 本地储存 （三）.Cookier 现实中为：饼干 程序员为：一种传值得方式 　　 相同点： 　　　 都保存在浏览器端，同源 ...

知识点： 一致性：https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/connectors/guarantees.html 1、主类 ...

idea方式一： a）添加flink-dist包 　 b)代码 c）启动5000端口 d) 启动flink对应的main函数 e) 打开界面 方式二： 方式二比方式一方便点，但是方式二一般用于本地测试，方式 ...

State Backend(状态的后端存储) 默认情况下，state会保存在taskmanager的内存中，checkpoint会存储在JobManager的内存中。 state 的store和checkpoint的位置取决于State Backend的配置 ...

1 Flink 应用程序启动 2 Checkpoint 保存与恢复 2.1 Checkpoin设置与保存 默认情况下，如果设置了Checkpoint选项，则Flink只保留最近成功生成的1个Checkpoint，而当Flink程序失败时 ...

在研发过程中，由于迭代更新的速度很快，API随着产品迭代不断调整，记录与通知API成为了一件麻烦事。而工具能很好的解决这一难题。 1、单个API通知 在我们使用Eolinker管理API的时候，希望通 ...

Checkpoint checkpoint是Flink容错的核心机制。它可以定期的将各个Operator处理的数据进行快照存储（Snapshot）。 如果Flink程序出现宕机，可以重新从这些快照中恢复数据。 Flink容错机制的核心就是持续创建分布式数据流及其状态的一致快照 ...