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