A basic code to monitor Flink job exception base on Akka
Apache Flink DashBoard is awesome, but weak at alerting. The code of this repo focus on how to monitor Flink Job and alert them.
| Actor name | restful url | hierarchy |
|---|---|---|
| ConfigActor | /config | akka.ConfigActor |
| OverviewActor | /overview | akka.OverviewActor |
| JobsActor | /jobs | akka.JobsActor |
| JobExceptionActor | /jobs/jobID/exceptions | akka.JobExceptionActor |
list as below
- Alert Module
- More API supported
- More Flink version supported