特牛网址导航

关于Flink的checkpoint的案例演示_flink hdfs checkpoint 样例-CSDN博客

网友收藏
文章浏览阅读1k次。编写Flink入门案例程序,词频统计WordCount,自定义数据源,产生数据:spark flink,设置Checkpoint,运行程序,查看Checkpoint检查点数据存储。代码:// TODO: ================= 建议必须设置 ===================// a. 设置Checkpoint-State的状态后端为FsStateBackend,本地测试时使用本地路径,集群测试时使用传入的HDFS的路径if (args.length < 1) { env._flink hdfs checkpoint 样例