目前，我有一个流式作业，它在收到特定触发器时触发批处理作业。
我想关注那个被触发的批处理作业，当它完成时，想在数据库中插入一个条目，比如弹性搜索等。
任何想法，我们如何实现这一目标？我们怎么能听那份工作呢？
问问题
52 次
1 回答
0
FLINK 提供了一些 REST API 来查询作业状态，您可以使用它来查询批处理作业状态：https ://ci.apache.org/projects/flink/flink-docs-release-1.12/ops/rest_api.html#jobs -工作。当任务运行时，它们的状态将报告给 JM。通过此 API，您可以根据请求的响应获取作业状态。
于 2020-12-03T05:57:42.957 回答