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

anauzrmj 于 2022-12-09 发布在 Apache

关注(0)|答案(1)|浏览(143)

使用Flink 1.11。我有一个要求来识别一个Flink任务是否面临反压力。使用webui，我们可以监控反压力状态。有没有办法在Flink应用程序中检查一个特定的任务是否面临反压力？

apache-flink

来源：https://stackoverflow.com/questions/72445677/how-to-check-if-flink-task-is-backpressured-programmatically

1条答案

按热度按时间

hgb9j2n61#

您应该能够使用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.

赞(0）回复(0）举报 2022-12-09

我来回答

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

1条答案

相关问题

热门标签

最新问答