如何实现flink作业失败告警功能

[casel.chen]

想实现flink作业一旦失败就立马告警功能，请问要如何实现？是否有Listener可以进行注册？