如何对flink基于数量的滑动窗口处理告警做性能测试

滑动窗口会导致一个时间点的数據会分布到多个window里来其它跟滚动窗口没区别

计算源是单个时间窗口内预汇聚的数据,不适用于滑动窗口的计算值比如前面单个窗口计算出来p90,那么滑动窗口的p90怎么算?

需要把前面的时间窗口的现场保留下来传到当前滑动窗口内才可以继续计算具体代码如下:

//拿到原始数據后,重新计算
 //1)在历史值和当前值中设置新的max值
 
主要就是这些,很难的点没有就是要注意各个细节





其实我觉得报警系统的精髓在于阈值的設置上,傻乎乎的设置静态值是没有技术含量的整个报警系统的精髓就在于自动设置报警阈值


所以接下来我会去研究这方面的技术,如果研究出来了我会发文章出来!













}

我要回帖

更多关于 flink基于数量的滑动窗口 的文章

更多推荐

版权声明:文章内容来源于网络,版权归原作者所有,如有侵权请点击这里与我们联系,我们将及时删除。

点击添加站长微信