0

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

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

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

4

1 回答 1

0

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

  1. ClientUtils.submitJob() -> 此方法适用于分离模式为 true
  2. ClientUtils.submitJobAndWaitForExecutionResult() -> 这作为分离模式工作为假。
于 2020-09-24T12:16:47.900 回答