如何检查Flink任务是否以编程方式反压



使用Flink 1.11。我需要确定Flink任务是否面临反向压力。通过web,我们可以监控背压状态。是否有任何方法检查Flink应用程序,如果一个特定的任务面临背压?

您应该能够使用Flink Job Manager REST API来获取背压信息: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.

最新更新