flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aitozi <...@git.apache.org>
Subject [GitHub] flink issue #6059: [Flink-9418] Migrate SharedBuffer to use MapState
Date Mon, 04 Jun 2018 08:21:18 GMT
Github user Aitozi commented on the issue:

    @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. 


View raw message