如何通过编程方式检查Flink任务是否是背压
使用Flink 1.11。我需要确定是否面对弯曲任务。使用WebUI，我们可以监视背压状态。如果特定任务面向背压，是否有任何方法可以检查Flink应用程序吗？
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 ?
如果你对这篇内容有疑问，欢迎到本站社区发帖提问 参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。
绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱，如果其他用户或者作者回复了您的评论，将不能在第一时间通知您！
发布评论
评论（1）
您应该能够使用Flink Job Manager REST API获取返回印刷信息： https://nightlies.apache.org/flink/flink/flink/flink-docs-stable/docs/docs/Rest_Api/rest_api/#jobs-jobid-vertices-vertices-vertices-vertices-vertices-vertices-vertices-vertices-vertices-vertices-vertices-vertices-vertices-vertices-vertices-vertices-vertexid-backpressure
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