There's no built-in mechanism to send notifications.

To monitor the job status you can poll the REST API. (*/jobs/:jobid)

*Alternatively you could implement a MetricReporter that explicitly checks for the availability metrics <https://ci.apache.org/projects/flink/flink-docs-master/monitoring/metrics.html#availability>,
regularly polls them and sends out notifications for irregular values.

For example if the upTime metric has decreased this always means something went wrong.

On 25.07.2018 09:52, ?????????? wrote:
dear all??
Is there a notification mechanism for Flink? When job's status changes, such as restart, failure, notify other systems??
Or
I have a system to monitor the job state of Flink. What should I do?

thanks


Reply via email to