如何检测Flink批处理作业完成



目前,我有一个流作业,当它接收到特定触发器时,它会触发批处理作业。

我想跟踪那个被解雇的批处理作业,当它完成时,我想插入一个数据库条目,比如弹性搜索之类的

有什么想法吗,我们如何才能做到这一点?我们怎么能听那份工作?

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

相关内容

  • 没有找到相关文章

最新更新