- 综合排序
- 最热优先
- 最新优先
- 来自专栏Lansonli技术博客
2021年大数据Flink（二十九）：Flink 容错机制 Savepoint
Checkpoint /export/server/flink/bin/flink savepoint 702b872ef80f08854c946a544f2ee1a5 hdfs://node1:8020/flink-checkpoint 702b872ef80f08854c946a544f2ee1a5 # 重新启动job,手动加载savepoint数据 /export/server/flink/bin/flink run -s hdfs://node1:8020/flink-checkpoint
74020发布于 2021-10-09 - 来自专栏大数据应用技术
Flink-Checkpoint&State案例测试
1s执行checkpoint操作 //状态后端 env.setStateBackend(new FsStateBackend("hdfs://hadoop10:8020/flink-checkpoint 关闭该作业，重新输入启动命令[root@hadoop10 app]# flink run -c day160616.CheckPointTest -s hdfs://hadoop10:8020/flink-checkpoint
25010编辑于 2024-07-25 - 来自专栏Lansonli技术博客
2021年大数据Flink（二十八）：Flink 容错机制 自动重启策略和恢复
:///D:/ckp")); }else{ env.setStateBackend(new FsStateBackend("hdfs://node1:8020/flink-checkpoint cn.checkpoint.CheckpointDemo01 5.取消任务 6.重新启动任务并指定从哪恢复 cn.itcast.checkpoint.CheckpointDemo01 hdfs://node1:8020/flink-checkpoint
3.1K10发布于 2021-10-09 - 来自专栏大数据应用技术
基于华为MRS3.2.0实时Flink消费Kafka落盘至HDFS的Hive外部表的调度方案
对于Kafka的权限在章节1.1已经获取，另外要保证有yarn资源的使用权限，还需要对HDFS的/flink、/flink-checkpoint目录获取权限，保证读，写，执行。
75810编辑于 2024-07-25 - 来自专栏Lansonli技术博客
2021年大数据Flink（二十七）：Flink 容错机制 Checkpoint
data\\ckp")); } else { env.setStateBackend(new FsStateBackend("hdfs://node1:8020/flink-checkpoint
1.3K30发布于 2021-10-09 - 来自专栏Lansonli技术博客
2021年大数据Flink（四十四）：扩展阅读 End-to-End Exactly-Once
//D:/ckp")); } else { env.setStateBackend(new FsStateBackend("hdfs://node1:8020/flink-checkpoint
97320发布于 2021-10-11 - 来自专栏五分钟学大数据
五万字 | Flink知识体系保姆级总结
StreamExecutionEnvironment.getExecutionEnvironment env.setStateBackend(new FsStateBackend("hdfs://hadoop01:9000/flink-checkpoint
5.6K52发布于 2021-09-22
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号