Flink里打包好的jar包上传运行，checkpoint在代码里可以设置oss-hdfs的地址么？

在 Flink 中，可以通过设置 CheckpointConfig 来配置检查点（Checkpoint）的相关参数，包括检查点的保存路径、检查点的触发间隔等。如果您想将检查点保存到 OSS 或 HDFS 等分布式文件系统中，可以设置对应的文件系统路径。
在 Flink 中，保存检查点的路径通常由以下两个参数决定：
state.backend.fs.checkpointdir：表示检查点数据存储的基础路径，通常是一个分布式文件系统的路径，例如 HDFS 或 OSS。
jobmanager.checkpoints.dir：表示检查点元数据存储的路径，通常也是一个分布式文件系统的路径，例如 HDFS 或 OSS。
如果您想将检查点保存到 OSS 或 HDFS 中，可以在 Flink 配置文件中设置这两个参数的值为对应的文件系统路径，例如：
Copy
state.backend.fs.checkpointdir: hdfs://hadoop-master:9000/flink-checkpoints
jobmanager.checkpoints.dir: hdfs://hadoop-master:9000/flink-checkpoints/metadata
需要注意的是，如果您在代码中设置了 CheckpointConfig 相关的参数值，那么这些参数值会覆盖 Flink 配置文件中的默认参数值。因此，在代码中设置参数值时，需要确保参数值与 Flink 配置文件中的参数值一致。

是的，在 Flink 中，可以通过代码设置 checkpoint 的存储地址为 OSS 或 HDFS。

在 Flink 代码中，您可以使用以下方式来设置 checkpoint 存储地址：

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

// 设置 checkpoint 配置
env.enableCheckpointing(60000); // 每分钟触发一次 checkpoint
env.getCheckpointConfig().setCheckpointStorage("oss://your_bucket/checkpoints"); // 设置 checkpoint 存储地址为 OSS

// 或者使用以下方式设置存储地址为 HDFS
env.getCheckpointConfig().setCheckpointStorage("hdfs://your_hdfs_path/checkpoints");

在上述代码中，env.enableCheckpointing(60000) 指定了每分钟触发一次 checkpoint。env.getCheckpointConfig().setCheckpointStorage("oss://your_bucket/checkpoints") 指定了 checkpoint 存储地址为 OSS 的桶的路径。您需要将 "oss://your_bucket/checkpoints" 替换为实际的 OSS 路径。

如果您想将 checkpoint 存储到 HDFS，只需将 setCheckpointStorage 方法中的参数修改为 HDFS 的路径即可。

总结而言，您可以在 Flink 代码中设置 checkpoint 的存储地址为 OSS 或 HDFS，通过 setCheckpointStorage 方法来指定。这样，打包好的 jar 包上传运行时，Flink 将会使用您指定的存储地址进行 checkpoint。

实时计算 Flink 产品 checkpoint 默认会落地到 oss 不需要自定义设置。 checkpoint 默认 3min 一次，10min 超时 timeout。此回答整理自钉群“实时计算Flink产品交流群”