问flink背压监测
EN

Stack Overflow用户

提问于 2018-06-18 10:04:41

回答 1查看 221关注 0票数 0

从我们的Flink项目开始。

由于繁重的解析代码，我的集群遭受了很低的背压。

因此，我在系统上放置了监控脚本，不断向任务管理器询问背压状态。(它每20秒运行一次，以获得最高值和平均值)

顺便说一句，当我关闭脚本运行时，我发现背压比的增量变得比使用脚本时慢得多。

那么，有没有什么有效的方法可以在不损失性能的情况下获得背压状态？

发布于 2018-06-18 22:05:00

我不认为每隔20秒请求一次背压会对你的工作流程的性能产生重大影响。

另外，如果您有可用的CPU周期，那么增加解析函数的并行度将是下一步尝试的事情，以提高吞吐量。

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/50901888

复制

相似问题

问flink背压监测EN