Github user Aitozi commented on the issue:
https://github.com/apache/flink/pull/6059
@dawidwys I'm sorry, I don't have a systematic testing tool. I'm working on
the inner dynamic cep and `CEPOperator` can process serveral `NFA` when receive
an element. Then i encounter the backpressure problem, i just test the patch if
can overcome the backpressure problem.
with this patch apply, 200 parallel CEPOperator can handle about 7000qps
data input with about 30 patterns(rule) without backpressue. The type of
pattern may have different influence, so the data I provide here may not be so
useful.
---
