flink群集详细信息，
节点数：4
flink版本：1.11
flink客户端：restcluserclient
我们使用packagedprogram从流式作业提交flink批处理作业，但是我们的要求是一次只执行一个作业，假设我们从源代码获得了2个事件，因此理想情况下必须触发2个批处理作业（每个事件），但一次只能触发一个。为了实现这一点，我们使用client.setdetached（false）（在flink的早期版本中），但是一旦我们将其迁移到1.11，setdetached（false）api就被删除了。
我们知道如何实现这个要求吗？
1条答案
按热度按时间wxclj1h51#
在进一步分析之后，我找到了解决办法。flink 1.11 api提供了提交作业的utils类，即clientutils，它有两个方法，
clientutils.submitjob（）->此方法将分离模式作为true使用
clientutils.submitjobandwaitforexecutionresult（）->这在分离模式下工作为false。