在Flink中，Checkpoint文件夹是用于保存检查点数据的位置。
如果你在YARN集群中运行Flink程序，并且之前没有指定Checkpoint文件夹的位置，你可以通过以下步骤创建Checkpoint文件夹：
1. 确定你在YARN集群中的运行模式。
Flink支持两种运行模式：Standalone模式和YARN模式。如果你是在YARN模式下运行Flink程序，请继续执行下一步；如果你是在Standalone模式下运行新建文件夹，你可以在Flink配置文件中直接指定Checkpoint文件夹的位置。
2.、登录到运行Flink的YARN集群的任意一台机器上。
3、找到Flink的配置目录。
在配置目录中，找到或创建一个名为`flink-conf.yaml`的配置文件。
4、 打开`flink-conf.yaml`文件，并添加以下配置属性：
state.checkpoints.dir: "hdfs:///path/to/checkpoint/dir"将`/path/to/checkpoint/dir`替换为你希望用作Checkpoint文件夹的HDFS路径。确保该路径在HDFS中是可写的。
在HDFS中，你可以选择一个合适的路径作为Checkpoint文件夹的位置。该路径需要在HDFS上是可写的，并且对应的用户具有适当的权限。
以下是填写和创建HDFS路径的一般步骤：
1. 首先，确定你要在HDFS上创建Checkpoint文件夹的位置。你可以选择一个已存在的目录或创建一个新目录。
2. 使用Hadoop命令行界面（Hadoop CLI）或Hadoop API中的`hadoop fs`命令，创建HDFS目录。例如，使用以下命令创建一个名为`checkpoint`的目录：
hdfs dfs -mkdir /path/to/checkpoint/dir确保你具有足够的权限执行此命令。
我的
报错原因是 在不存在的文件夹里面创建子文件夹；
解决方案，创建一层不存在的文件夹就可以了
3. 确认Checkpoint文件夹已成功创建。你可以使用以下命令来验证：
娜娜项目网每日更新创业和副业项目
网址：nanaxm.cn 点击前往娜娜项目网
站 长 微 信： nanadh666
hdfs dfs -ls /path/to/checkpoint/dir
如果成功创建，你应该能够看到新创建的Checkpoint文件夹。
4. 在Flink配置文件（如`flink-conf.yaml`）中，将`state.checkpoints.dir`属性设置为你刚创建的Checkpoint文件夹的HDFS路径。例如：
state.checkpoints.dir: hdfs:///hdfs确保你在配置文件中使用的路径与实际创建的Checkpoint文件夹路径一致。
填写和创建HDFS路径需要确保HDFS集群正常运行，并且你在执行命令时具有足够的权限。完成上述步骤后，Flink将会将Checkpoint数据保存在指定的HDFS路径中。
5.、保存并关闭`flink-conf.yaml`文件
6、 确保你的Flink程序中启用了Checkpoint
在程序的代码中添加类似以下的配置：
env.enableCheckpointing(5000); //设置checkpoint间隔5000毫秒
env.setStateBackend(new FsStateBackend("hdfs:///hdfs"));//设置保存checkpoint的位置7、 提交你的Flink程序到YARN集群
你可以使用Flink提供的命令行工具或API进行提交。
一旦你完成了上述步骤新建文件夹，Flink程序将会在指定的Checkpoint文件夹中创建Checkpoint数据。请确保Checkpoint文件夹的路径在YARN集群中是可访问的，并且具有适当的权限。
然后查看
娜娜项目网每日更新创业和副业项目
网址：nanaxm.cn 点击前往娜娜项目网
站 长 微 信： nanadh666