job status monitor

[26304659]

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

[Renjie Liu]

You can use rest api here https://ci.apache.org/projects/flink/flink-docs-release-1.5/monitoring/rest_api.html

On Wed, Jul 25, 2018 at 5:18 PM 从六品州同 <[hidden email]> 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

--

[Chesnay Schepler]

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,
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