Using Flink 1.11. I have a requirement to identify if a Flink task is facing back pressured. Using webui , we can monitor backpressure status. Is there any way to check in Flink Application if a particular task is facing backpressure ?
1 Answers
You should be able to use the Flink Job Manager REST API to get back-pressure information: https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/rest_api/#jobs-jobid-vertices-vertexid-backpressure
/jobs/:jobid/vertices/:vertexid/backpressure
Returns back-pressure information for a job, and may initiate back-pressure sampling if necessary.
Related