0
点赞
收藏
分享

微信扫一扫

Flink中的JobListener官方文档

绣文字 2022-03-30 阅读 58


ExecutionEnvironment 与 StreamExecutionEnvironment 均有 registerJobListener 方法,可以传进一个 JobListener,在作业提交以及完成的时候调用对应方法。当然,这需要你提交作业的客户端程序一直存在,直到作业完成并且对应函数被调用。

https://nightlies.apache.org/flink/flink-docs-master/api/java/org/apache/flink/api/java/ExecutionEnvironment.html#registerJobListener-org.apache.flink.core.execution.JobListener-

https://nightlies.apache.org/flink/flink-docs-master/api/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.html#registerJobListener-org.apache.flink.core.execution.JobListener-

https://nightlies.apache.org/flink/flink-docs-master/api/java/org/apache/flink/core/execution/JobListener.html



举报

相关推荐

0 条评论