apache-flink - 是否可以通过编程方式设置 flink `state.checkpoint.dir` ？

Question

我们有用于在项目中本地运行的flink-conf.yaml。我们希望能够在本地运行 flink 进行测试。我们团队的一部分使用 Mac，另一部分使用 PC。我们希望将 state.checkpoint.dir 设置为一些普遍可接受的路径，最好位于用户的主目录下。问题是，是否可以根据我们运行的操作系统以编程方式设置它，如果没有，在此设置中当前用户的主目录是否有一个普遍有效的快捷方式，例如 *NIX 上的“~”？

Answer 1

以下示例展示了如何以编程方式设置 Flink 的配置设置:

Configuration conf = new Configuration();
conf.setString("state.checkpoints.dir", "file:///tmp/checkpoints");

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(conf);

System.getProperty("os.name") 将告诉您客户端正在哪个操作系统上运行，这对于本地运行来说应该足够了。

您还可以从命令行设置任何配置参数，例如

flink run -Dstate.checkpoints.dir="/tmp/checkpoints" foo.jar

代码中的设置优先于命令行，命令行优先于flink-conf.yaml。