flink实战–flink的job_listener使用解析

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

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

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

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

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

  void onJobExecuted(@Nullable JobExecutionResult v

显示所有内容

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