鲲鹏社区首页
中文
注册
我要评分
文档获取效率
文档正确性
内容完整性
文档易理解
在线提单
论坛求助

Flink运行时测试背压问题的解决方法

问题现象描述

Flink运行时为窗口运行,该用例中每10s为一个窗口,落入该窗口的数据,均在该窗口进行处理,但是由于系统突发的不稳定现象,系统接收数据的速率高于它在一个瞬时脉冲内能处理的数据,从而形成背压,导致后续数据处理都出现时延的大幅上升。

关键过程、根本原因分析

结论、解决方案及效果

为了防止背压对性能产生的影响,测试数据只取测试时间内无背压时的测试结果。