flink实战–flink的job_listener使用解析

本文介绍: 自定义listener，只需要实现对应的接口。并将您的逻辑写入重写的函数中。Flink JobListener 接口有两种方法，一种是提交，一种是完成。接口的定义如下。两种方法都有两个参数。一个常见的参数是 Throwable。Throwable 参数是进程抛出的错误（如果有）。让我们分别看看这两种方法。Flink JobListener接口：onJobSubmitted顾名思义，只要提交作业以供执行，就会调用此函数内的代码，并调用该方法。

背景

生产环境可能有如下的需求：当一个flink作业提交完成或者是运行中不定时给我们触发某个接口或发送一个消息，然后我们在做其他的操作，尤其是batch作业。 flink的job_listener就可以满足我们监听flink任务提交和运行状态的需求，具体如何使用本文将全面介绍一下。

注册入口

ExecutionEnvironment 与 StreamExecutionEnvironment 均有 registerJobListener 方法，可以传进一个自定义的 JobListener，在作业提交以及完成的时候调用对应方法。

注：只有作业提交完成或者运行完成才会调用对应的监听方法

自定义job_listener

自定义listener，只需要实现对应的接口。并将您的逻辑写入重写的函数中。Flink JobListener 接口有两种方法，一种是提交，一种是完成。接口的定义如下。

interface JobListener {
  void onJobSubmitted(@Nullable JobClient var1, @Nullable Throwable var2);

  void onJobExecuted(@Nullable JobExecutionResult v

原文地址:https://blog.csdn.net/aA518189/article/details/136021195

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。

如若转载，请注明出处：http://www.7code.cn/show_66609.html

如若内容造成侵权/违法违规/事实不符，请联系代码007邮箱：suwngjj01@126.com进行投诉反馈，一经查实，立即删除！

声明：本站所有文章，如无特殊说明或标注，均为本站原创发布。任何个人或组织，在未征得本站同意时，禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益，可联系我们进行处理。