【发布时间】:2020-12-02 16:27:51
【问题描述】:
目前,我有一个流式作业,它在收到特定触发器时触发批处理作业。
我想关注那个被触发的批处理作业,当它完成时,我想在数据库中插入一个条目,比如弹性搜索等。
任何想法,我们如何实现这一目标?我们怎样才能听那份工作?
【问题讨论】:
标签: apache-flink flink-streaming data-processing flink-batch
目前,我有一个流式作业,它在收到特定触发器时触发批处理作业。
我想关注那个被触发的批处理作业,当它完成时,我想在数据库中插入一个条目,比如弹性搜索等。
任何想法,我们如何实现这一目标?我们怎样才能听那份工作?
【问题讨论】:
标签: apache-flink flink-streaming data-processing flink-batch
FLINK 提供了一些 REST API 来查询作业状态,您可以使用这个 API 来查询批处理作业状态:https://ci.apache.org/projects/flink/flink-docs-release-1.12/ops/rest_api.html#jobs-jobid。任务运行时,它们的状态将报告给 JM。通过此 API,您可以根据请求的响应获取作业状态。
【讨论】: