首页 > TAG信息列表 > 1Flink
从0到1Flink的成长之路(二十)-Flink 高级特性（二）之状态恢复和重启策略
状态恢复和重启策略 手动重启并恢复 1.把程序打包 2.启动Flink集群(本地单机版，集群版都可以) /export/server/flink/bin/start-cluster.sh 3.访问webUI http://node1.itcast.cn:8081/#/overview 4.使用FlinkWebUI提交 cn.itcast.flink.checkpoint.StreamCheckpointDem从0到1Flink的成长之路(二十)-Flink 高级特性（二）之存储 State 数据结构
存储 State 数据结构 前面说过：有状态计算其实就是需要考虑历史数据，而历史数据需要搞个地方存储起来。 Flink为了方便不同分类的State的存储和管理，提供了如下API/数据结构来存储State。 1）、Keyed State Keyed State 通过 RuntimeContext 访问，这需要 Operator 是一个RichFunct从0到1Flink的成长之路(十七)-高级特性(Flink四大基石)
Flink 高级特性（一） 1. Flink 四大基石 Flink之所以能这么流行，离不开它最重要的四个基石：Checkpoint、State、Time、Window。 Checkpoint Flink最重要的一个特性，Flink基于Chandy-Lamport算法实现了一个分布式的一致性的快 照，从而提供了一致性的语义。 Chandy-Lamport算法实际上