使用 Java 设置 Flink 分离模式答案

【问题标题】：Set Flink Detached Mode using Java使用 Java 设置 Flink 分离模式
【发布时间】：2020-09-22 13:50:56
【问题描述】：

Flink 集群详细信息，
节点数：4
Flink 版本：1.11
Flink 客户端：RestCluserClient

我们使用 PackagedProgram 从流式作业提交 Flink 批处理作业，但我们的要求是一次只执行一个作业，假设我们从源获得 2 个事件，因此理想情况下必须触发 2 个批处理作业（每个事件每个）但是一次只有一个。为了实现这一点，我们使用了 client.setDetached(false)（在之前的 flink 版本中），但是一旦我们将它迁移到 1.11，setDetached(false) API 就被移除了。

我们知道如何实现这个要求吗？

【问题讨论】：

标签： apache-flink flink-streaming flink-batch

【解决方案1】：

在对此进行了更多分析之后，我找到了解决方案。 Flink 1.11 API 提供了用于提交作业的 Utils 类，即ClientUtils，它有两种方法，

ClientUtils.submitJob() -> 此方法适用于分离模式为 true
ClientUtils.submitJobAndWaitForExecutionResult() -> 分离模式为 false。

【讨论】：