时间戳

首页 > 解决方案 > 没有 ./bin/flink 的保存点

apache-flink - 没有 ./bin/flink 的保存点

问题描述

  1. 是否可以从具有直接 main() + LocalExecutionEnvironment 设置的保存点运行作业？
  2. 是否可以通过 Remote*Environment 做到这一点？
  3. 是否可以这样做或通过 ClusterClient 触发保存点？
  4. 以上是否可以通过rest api实现？Web ui（看起来不像）？
  5. 最后，是否可以从本地 ./bin/flink 对远程集群（相同版本但可能不同的操作系统）执行保存点操作？

谢谢你。

标签： apache-flinkflink-streaming

解决方案

要部分回答 (3)，您可以使用 aClusterClient通过执行类似以下操作来做到这一点：

final Configuration config = GlobalConfiguration.loadConfiguration("...");
final ClusterClient client = new StandaloneClusterClient(config);

final PackagedProgram packagedProgram = new PackagedProgram(new File(FLINK_JOB_JAR));
packagedProgram.setSavepointRestoreSettings(SavepointRestoreSettings.forPath("...", true));

client.run(packagedProgram, 1);

推荐阅读