apache-flink - 如何检测 Flink Batch Job 是否完成

Question

目前，我有一个流式作业，它在收到特定触发器时触发批处理作业。

我想关注那个被触发的批处理作业，当它完成时，想在数据库中插入一个条目，比如弹性搜索等。

任何想法，我们如何实现这一目标？我们怎么能听那份工作呢？

标签： apache-flinkflink-streamingdata-processingflink-batch

Answer 1

FLINK 提供了一些 REST API 来查询作业状态，您可以使用它来查询批处理作业状态：https ://ci.apache.org/projects/flink/flink-docs-release-1.12/ops/rest_api.html#jobs -工作。当任务运行时，它们的状态将报告给 JM。通过此 API，您可以根据请求的响应获取作业状态。