flink cep超时时间匹配有遗漏和误匹配

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

flink cep超时时间匹配有遗漏和误匹配

邵志鹏
最近测试发现:flink cep超时事件匹配有遗漏和误匹配


1. 大约超时并发量达到10000 时,简单的a.next(b) ,5分钟超时时间,5分钟后实际的超时事件OutputTag输出一般会少10个以内不等,偶尔也会超过10个
2. 大约超时并发量在2000和以上时,a.nex(b),5分钟超时时间,5分钟内内a,b事件都正常到达,但是却从超时OutputTag中输出了超时事件,一般2000里面有150左右;2万条里面有2000多左右。


请问有CEP 超时这方面经验的大佬,这是正常情况吗。。。


flink版本1.7.2


谢谢~