diagnose_job
Provides a one-call health verdict for a Flink job by combining state, task status, exceptions, checkpoints, backpressure, and source lag into ranked findings to explain why it is unhealthy or slow.
Instructions
One-call health verdict for a job: combines state, task status, exceptions,
checkpoints, backpressure and source lag into ranked findings. Start here when asked
"why is this job unhealthy/slow?". When Prometheus is configured it also reports trends
over the last history (default "1h"; "off" to skip): restarts, checkpoint failures and
durations, sustained backpressure. Those are observations with their metric and window,
not causes; a Prometheus problem never changes the live diagnosis.
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| job_id | Yes | ||
| cluster | No | ||
| history | No | 1h |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||