背景

         生产环境可能有如下的需求：当一个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